nsavin / catamqp Goto Github PK

catamqp.py is a simple command to listen AMQP server exchange.

Features: 
  * try to decode message body as JSON and format it. 
    Or output as string if failed
  * with key '-t' listen 'amq.rabbitmq.trace' exchange and 
    write output in file (by default, 'trace.log')

Examples: 
  # output on screen messages 
  ./catamqp.py nova
  # write output in file 
  ./catamqp.py -f nova.log nova
  # specify route key 
  ./catamqp.py -r nova.* nova
  # trace messages
  ./catamqp.py -t 
  # trace only publish
  ./catamqp.py -t -r publish.* 
  # output trace on screen instead of file, trace only publish 
  # messages in nova exchange
  ./catamqp.py -t -f - -r publish.nova

Tracing: 
  Rabbitmq has to be >= 2.6. Upgrade if needed. 
  To enable trace:
  * rabbitmq-plugins enable rabbitmq_tracing
  * service rabbitmq-server restart
  * rabbitmqctl trace_on
  To disable trace:
  * rabbitmqctl trace_off

  Traced messages publsished in exchange 'amq.rabbitmq.trace', with fields: 
  * routing key 
    * "publish.exchangename", for messages entering the broker
    * "deliver.queuename", for messages leaving the broker
    * "info", "warn", "error" - internal
  * headers containing metadata about the original message: all its headers, properties, and a few other things
  * body corresponding to the body of the original message