# Depends on Faraday 2.x gem 'rabbitmq_http_api_client', '>= 3.0.0'

# Depends on Faraday 1.x. # Consider using 3.0.0 and later versions. gem 'rabbitmq_http_api_client', '>= 2.2.0'

require "rabbitmq/http/client"

require "rabbitmq/http/client" endpoint = "http://127.0.0.1:15672" client = RabbitMQ::HTTP::Client.new(endpoint, username: "guest", password: "guest")

require "rabbitmq/http/client" client = RabbitMQ::HTTP::Client.new("http://guest:guest@127.0.0.1:15672")

r = client.overview puts r[:rabbitmq_version] puts r.erlang_version

c = RabbitMQ::HTTP::Client.new("https://127.0.0.1:15672/", username: "guest", password: "guest", ssl: { client_cer: ..., client_key: ..., ca_file: ..., ca_path: ..., cert_store: ... })

c = RabbitMQ::HTTP::Client.new("https://127.0.0.1:15672/", username: "guest", password: "guest", ssl: { verify: false })

# Get cluster information overview h = client.overview # List cluster nodes with detailed status info for each one of them nodes = client.list_nodes n = nodes.first puts n.mem_used puts n.run_queue # Get detailed status of a node n = client.node_info("rabbit@localhost") puts n.disk_free puts n.proc_used puts n.fd_total # Get Management Plugin extension list xs = client.list_extensions # List all the entities (vhosts, queues, exchanges, bindings, users, etc) defs = client.list_definitions

# List all connections to a node conns = client.list_connections conn = conns.first puts conn.name puts conn.client_properties.product # Get a connection information by name conns = client.list_connections conn = client.connection_info(conns.first.name) puts conn.name puts conn.client_properties.product # Forcefully close a connection conns = client.list_connections client.close_connection(conns.first.name)

# List all channels channs = client.list_channels ch = channs.first puts ch.number puts ch.prefetch_count puts ch.name # Get a channel information by name conns = client.list_channels conn = client.channel_info(conns.first.name) puts conn.name

# List all exchanges in the cluster xs = client.list_exchanges x = xs.first puts x.type puts x.name puts x.vhost puts x.durable puts x.auto_delete # List all exchanges in a vhost xs = client.list_exchanges("myapp.production") x = xs.first puts x.type puts x.name puts x.vhost # Get information about an exchange in a vhost x = client.exchange_info("/", "log.events") puts x.type puts x.name puts x.vhost # List all exchanges in a vhost for which an exchange is the source client.list_bindings_by_source("/", "log.events") # List all exchanges in a vhost for which an exchange is the destination client.list_bindings_by_destination("/", "command.handlers.email")

# List all queues in a node qs = client.list_queues q = qs.first puts q.name puts q.auto_delete puts q.durable puts q.backing_queue_status puts q.active_consumers # Get information about a queue client.queue_info("/", "collector1.megacorp.local") # Declare a queue client.declare_queue("/", "collector1.megacorp.local", :durable => false, :auto_delete => true) # Delete a queue client.delete_queue("/", "collector1.megacorp.local") # List bindings for a queue bs = client.list_queue_bindings("/", "collector1.megacorp.local") # Purge a queue client.purge_queue("/", "collector1.megacorp.local") # Fetch messages from a queue ms = client.get_messages("/", "collector1.megacorp.local", :count => 10, :requeue => false, :encoding => "auto") m = ms.first puts m.properties.content_type puts m.payload puts m.payload_encoding

# List all bindings bs = client.list_bindings b = bs.first puts b.destination puts b.destination_type puts b.source puts b.routing_key puts b.vhost # List all bindings in a vhost bs = client.list_bindings("/") # List all bindings between an exchange and a queue bs = client.list_bindings_between_queue_and_exchange("/", "collector1.megacorp.local", "log.events")

# List all vhosts vs = client.list_vhosts v = vs.first puts v.name puts v.tracing # Get information about a vhost v = client.vhost_info("/") puts v.name puts v.tracing # Create a vhost client.create_vhost("myapp.staging") # Delete a vhost client.delete_vhost("myapp.staging")

# List all users us = client.list_users u = us.first puts u.name puts u.password_hash puts u.tags # Get information about a user u = client.user_info("guest") puts u.name puts u.password_hash puts u.tags # Update information about a user client.update_user("myapp", :tags => "services,policymaker,management", :password => "t0ps3krEt") # Delete a user client.delete_user("myapp")

# List all permissions ps = client.list_permissions puts p.user puts p.read puts p.write puts p.configure puts p.vhost # List all permissions in a vhost ps = client.list_permissions("/") puts p.user puts p.read puts p.write puts p.configure puts p.vhost # List permissions of a user ps = client.user_permissions("guest") # List permissions of a user in a vhost ps = client.list_permissions_of("/", "guest") # Update permissions of a user in a vhost ps = client.update_permissions_of("/", "guest", :write => ".*", :read => ".*", :configure => ".*") # Clear permissions of a user in a vhost ps = client.clear_permissions_of("/", "guest")