class LavinMQCtl

• LavinMQCtl
• Reference
• Object

Defined in:

lavinmq/definitions_generator.cr
lavinmqctl.cr

Constant Summary

COMPAT_CMDS = { {"add_user", "Creates a new user", "<username> <password>"}, {"change_password", "Change the user password", "<username> <new_password>"}, {"delete_user", "Delete a user", "<username>"}, {"list_users", "List user names and tags", ""}, {"set_user_tags", "Sets user tags", "<username> <tags>"}, {"list_vhosts", "Lists virtual hosts", ""}, {"add_vhost", "Creates a virtual host", "<vhost>"}, {"delete_vhost", "Deletes a virtual host", "<vhost>"}, {"clear_policy", "Clears (removes) a policy", "<name>"}, {"list_policies", "Lists all policies in a virtual host", ""}, {"list_connections", "Lists AMQP 0.9.1 connections for the node", ""}, {"list_queues", "Lists queues and their properties", ""}, {"purge_queue", "Purges a queue (removes all messages in it)", "<queue>"}, {"pause_queue", "Pause all consumers on a queue", "<queue>"}, {"resume_queue", "Resume all consumers on a queue", "<queue>"}, {"delete_queue", "Delete queue", "<queue>"}, {"export_definitions", "Exports definitions in JSON", ""}, {"import_definitions", "Import definitions in JSON", "<file>"}, {"close_all_connections", "Instructs the broker to close all connections for the specified vhost or entire node", "<reason>"}, {"close_connection", "Instructs the broker to close a connection by pid", "<pid> <reason>"}, {"stop_app", "Stop the AMQP broker", ""}, {"start_app", "Starts the AMQP broker", ""}, {"list_exchanges", "Lists exchanges", ""}, {"delete_exchange", "Delete exchange", "<name>"}, {"set_vhost_limits", "Set VHost limits (max-connections, max-queues)", "<json>"}, {"set_permissions", "Set permissions for a user", "<username> <configure> <write> <read>"} }

Constructors

• .new

Instance Method Summary

• #banner=(banner : String)
• #run_cmd

  ameba:disable Metrics/CyclomaticComplexity

Constructor Detail

Instance Method Detail