¿Es posible ver el contenido de los mensajes de RabbitMQ directamente desde la línea de comandos?

¿Es posible ver el contenido de los mensajes de RabbitMQ directamente desde la línea de comandos?

sudo rabbitmqctl list_queues enumera las colas.

¿Hay algún comando como sudo rabbitmqctl list_queue_messages <queue_name>?

Debe habilitar el complemento de administración.

rabbitmq-plugins enable rabbitmq_management

Mira aquí:

http://www.rabbitmq.com/plugins.html

Y aquí para los detalles de la gestión.

http://www.rabbitmq.com/management.html

Finalmente, una vez configurado, deberá seguir las instrucciones a continuación para instalar y usar la herramienta rabbitmqadmin. Que se puede utilizar para interactuar completamente con el sistema. http://www.rabbitmq.com/management-cli.html

Por ejemplo:

rabbitmqadmin get queue=<QueueName> requeue=false

le dará el primer mensaje de la cola.

Estos son los comandos que utilizo para obtener el contenido de la cola:

RabbitMQ versión 3.1.5 en Fedora Linux usando https://www.rabbitmq.com/management-cli.html

Aquí están mis intercambios:

eric@dev ~ $ sudo python rabbitmqadmin list exchanges
+-------+--------------------+---------+-------------+---------+----------+
| vhost |        name        |  type   | auto_delete | durable | internal |
+-------+--------------------+---------+-------------+---------+----------+
| /     |                    | direct  | False       | True    | False    |
| /     | kowalski           | topic   | False       | True    | False    |
+-------+--------------------+---------+-------------+---------+----------+

Aquí está mi cola:

eric@dev ~ $ sudo python rabbitmqadmin list queues
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+
| vhost |   name   | auto_delete | consumers | durable | exclusive_consumer_tag |     idle_since      | memory | messages | messages_ready | messages_unacknowledged |        node         | policy | status  |
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+
| /     | myqueue  | False       | 0         | True    |                        | 2014-09-10 13:32:18 | 13760  | 0        | 0              | 0                       |rabbit@ip-11-1-52-125|        | running |
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+

Meta algunos elementos en myqueue:

curl -i -u guest:guest http://localhost:15672/api/exchanges/%2f/kowalski/publish -d '{"properties":{},"routing_key":"abcxyz","payload":"foobar","payload_encoding":"string"}'
HTTP/1.1 200 OK
Server: MochiWeb/1.1 WebMachine/1.10.0 (never breaks eye contact)
Date: Wed, 10 Sep 2014 17:46:59 GMT
content-type: application/json
Content-Length: 15
Cache-Control: no-cache

{"routed":true}

RabbitMQ ve mensajes en cola:

eric@dev ~ $ sudo python rabbitmqadmin get queue=myqueue requeue=true count=10
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+
| routing_key | exchange | message_count |                        payload        | payload_bytes | payload_encoding | properties | redelivered |
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+
| abcxyz      | kowalski | 10            | foobar                                | 6             | string           |            | True        |
| abcxyz      | kowalski | 9             | {'testdata':'test'}                   | 19            | string           |            | True        |
| abcxyz      | kowalski | 8             | {'mykey':'myvalue'}                   | 19            | string           |            | True        |
| abcxyz      | kowalski | 7             | {'mykey':'myvalue'}                   | 19            | string           |            | True        |
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+

Escribí rabbitmq-dump-queue que permite volcar mensajes de una cola de RabbitMQ a archivos locales y volver a colocar los mensajes en su orden original.

Ejemplo de uso (para volcar los primeros 50 mensajes de la cola incoming_1):

rabbitmq-dump-queue -url="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp

puede usar la API de RabbitMQ para obtener recuentos o mensajes:

/api/queues/vhost/name/get

Recibe mensajes de una cola. (Esto no es un HTTP GET ya que alterará el estado de la cola). Debes publicar un cuerpo que se parezca a:

{"count":5,"requeue":true,"encoding":"auto","truncate":50000}

count controla el número máximo de mensajes a recibir. Puede recibir menos mensajes que este si la cola no puede proporcionarlos de inmediato.

requeue determina si los mensajes se eliminarán de la cola. Si la cola es verdadera, se pondrán en cola, pero se establecerá su marca de reenvío. la codificación debe ser "automática" (en cuyo caso la carga útil se devolverá como una cadena si es UTF-8 válido, y codificada en base64 en caso contrario) o "base64" (en cuyo caso la carga útil siempre estará codificada en base64). Si truncar está presente, truncará la carga útil del mensaje si es mayor que el tamaño dado (en bytes). truncar es opcional; todas las demás claves son obligatorias.

Tenga en cuenta que las rutas de publicación / obtención en la API HTTP están destinadas a inyectar mensajes de prueba, diagnósticos, etc., no implementan una entrega confiable y, por lo tanto, deben tratarse como una herramienta de administrador de sistemas en lugar de una API general para mensajería.

http://hg.rabbitmq.com/rabbitmq-management/raw-file/rabbitmq_v3_1_3/priv/www/api/index.html

un poco tarde para esto, pero sí, rabbitmq tiene un trazador incorporado que le permite ver los mensajes entrantes en un registro. Cuando está habilitado, puede simplemente tail -f /var/tmp/rabbitmq-tracing/.log(en mac) ver los mensajes.

la descripción detallada está aquí http://www.mikeobrien.net/blog/tracing-rabbitmq-messages

Si desea varios mensajes de una cola, digamos 10 mensajes, el comando a utilizar es:

rabbitmqadmin get queue=<QueueName> ackmode=ack_requeue_true count=10

Si no desea que los mensajes se pongan en cola, simplemente cambie ackmodea ack_requeue_false.