Monitoring RabbitMQ

Plumber supports reading/writing/relay from RabbitMQ

RabbitMQ

Reading

plumber read rabbitmq --url "amqp://guest:guest@localhost:5672/" --queue my_queue

Writing

  --url "amqp://guest:[email protected]:5672/" \
  --exchange my_exchange \
  --routing-key my_routing_key \
  --input '{"id": "1224", "name": "John Q Customer"}'

Relaying

    -e PLUMBER_RELAY_TOKEN=$YOUR-STREAMDAL-TOKEN-HERE \
    -e PLUMBER_RELAY_RABBITMQ_URL="amqp://guest:[email protected]:5672/" \
    -e PLUMBER_RELAY_RABBITMQ_QUEUE="my_queue" \
    streamdal/plumber relay rabbitmq

Remember to replace placeholders such as my_queue, my_exchange, my_routing_key, and amqp://guest:[email protected]:5672/ with your actual RabbitMQ configuration. The Docker command assumes you have a Docker image called streamdal/plumber that is configured to relay messages from RabbitMQ. Be sure to replace the placeholder $YOUR-STREAMDAL-TOKEN-HERE with your actual Streamdal.com token.