Messaging Basic Auth

RabbitMQ REST API

Open-source message broker for reliable messaging

RabbitMQ is a widely-deployed open-source message broker that supports multiple messaging protocols including AMQP, MQTT, and STOMP. Developers use RabbitMQ to decouple applications, implement asynchronous processing, and build event-driven architectures with features like message queuing, routing, clustering, and high availability. The Management HTTP API enables programmatic control of queues, exchanges, bindings, and monitoring.

Base URL http://localhost:15672/api

API Endpoints

Method	Endpoint	Description
GET	`/overview`	Get cluster-wide overview including node information, message rates, and queue totals
GET	`/nodes`	List all nodes in the RabbitMQ cluster with status and resource usage
GET	`/connections`	List all currently open client connections with connection details
GET	`/channels`	List all active channels across all connections
GET	`/exchanges`	List all exchanges across all virtual hosts
GET	`/exchanges/{vhost}/{name}`	Get details of a specific exchange including bindings and configuration
PUT	`/exchanges/{vhost}/{name}`	Create or update an exchange with specific type and properties
DELETE	`/exchanges/{vhost}/{name}`	Delete an exchange from the specified virtual host
GET	`/queues`	List all queues across all virtual hosts with message counts and rates
GET	`/queues/{vhost}/{name}`	Get detailed information about a specific queue including consumers and messages
PUT	`/queues/{vhost}/{name}`	Create or update a queue with durability, auto-delete, and other properties
DELETE	`/queues/{vhost}/{name}`	Delete a queue and optionally remove all messages
GET	`/bindings`	List all bindings between exchanges and queues
POST	`/bindings/{vhost}/e/{exchange}/q/{queue}`	Create a binding between an exchange and a queue with routing key
POST	`/queues/{vhost}/{name}/get`	Get messages from a queue with acknowledgment options

Code Examples

# Get overview of RabbitMQ cluster
curl -u guest:guest \
  http://localhost:15672/api/overview

# Create a new queue
curl -u guest:guest \
  -X PUT \
  -H 'Content-Type: application/json' \
  -d '{"durable":true,"auto_delete":false}' \
  http://localhost:15672/api/queues/%2F/my-queue

# List all queues
curl -u guest:guest \
  http://localhost:15672/api/queues

// Get all queues
const response = await fetch('http://localhost:15672/api/queues', {
  method: 'GET',
  headers: {
    'Authorization': 'Basic ' + btoa('guest:guest'),
    'Content-Type': 'application/json'
  }
});
const queues = await response.json();
console.log(queues);

// Create a new exchange
const createExchange = await fetch('http://localhost:15672/api/exchanges/%2F/my-exchange', {
  method: 'PUT',
  headers: {
    'Authorization': 'Basic ' + btoa('guest:guest'),
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    type: 'topic',
    durable: true,
    auto_delete: false
  })
});

// Bind queue to exchange
const binding = await fetch('http://localhost:15672/api/bindings/%2F/e/my-exchange/q/my-queue', {
  method: 'POST',
  headers: {
    'Authorization': 'Basic ' + btoa('guest:guest'),
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    routing_key: 'events.*'
  })
});

import requests
from requests.auth import HTTPBasicAuth

# Authentication
auth = HTTPBasicAuth('guest', 'guest')
base_url = 'http://localhost:15672/api'

# Get cluster overview
response = requests.get(f'{base_url}/overview', auth=auth)
print(response.json())

# Create a durable queue
queue_config = {
    'durable': True,
    'auto_delete': False,
    'arguments': {'x-max-length': 10000}
}
response = requests.put(
    f'{base_url}/queues/%2F/my-queue',
    json=queue_config,
    auth=auth
)

# Get queue details
response = requests.get(f'{base_url}/queues/%2F/my-queue', auth=auth)
queue_info = response.json()
print(f"Messages: {queue_info['messages']}")
print(f"Consumers: {queue_info['consumers']}")

# Create binding
binding_config = {'routing_key': 'user.created'}
response = requests.post(
    f'{base_url}/bindings/%2F/e/events/q/my-queue',
    json=binding_config,
    auth=auth
)

Connect RabbitMQ to AI

Deploy a RabbitMQ MCP server on IOX Cloud and connect it to Claude, ChatGPT, Cursor, or any AI client. Your AI assistant gets direct access to RabbitMQ through these tools:

rabbitmq_create_queue Create a new message queue with specified durability, TTL, and dead letter exchange settings

rabbitmq_publish_message Publish a message to an exchange with routing key and optional headers

rabbitmq_get_queue_stats Retrieve queue statistics including message counts, consumer counts, and message rates

rabbitmq_create_binding Create a binding between an exchange and queue with routing patterns

rabbitmq_monitor_cluster Monitor cluster health, node status, memory usage, and connection metrics

Deploy in 60 seconds

Describe what you need, AI generates the code, and IOX deploys it globally.

Deploy RabbitMQ MCP Server →

RabbitMQ REST API

API Endpoints

Code Examples

Connect RabbitMQ to AI

Deploy in 60 seconds

Related APIs