Данный запрос можно делать даже из bash в Linux так как используются стандартные инструменты.
Все необходимое (обменник, очереди) можно создать через WEB-интерфейс RabbitMQ Managment. Предполагаем , что они уже созданы.
Отправляем сообщение в очередь.
В примере ниже :
vhost — имя хоста (exchanges)
delivery_mode 2 — записываем в режиме когда данные очереди сохраняются даже после падения сервера (сохраняются на диск)
routing_key — имя нашей очереди
payload — в данном случае строка , которую мы передаем в сообщении
%2F/amq.default — имя обменника внутри хоста
curl -s -u user:password -H "Accept: application/json" -H "Content-Type:application/json" -X POST -d'{
"vhost": "Test_Virtual_Host",
"properties": {
"delivery_mode": 2,
"headers": {}
},
"routing_key": "testqueues",
"payload":"/dfgdfgfd/dfgdfg/dfgdfgfdg.dat",
"headers": {},
"props": {},
"payload_encoding": "string"
}' http://127.0.0.1:15672/api/exchanges/%2F/amq.default/publish
Читаем сообщение.
curl -s -u user:password -H "content-type:application/json" -X POST -d'{
"count":2,
"ackmode":"ack_requeue_false",
"encoding":"auto",
"truncate":5000
}' http://127.0.0.1:15672/api/queues/%2F/testqueues/get
Удалить обменник через curl.
curl -s -u admin:1234567890 -X DELETE http://127.0.0.1:15672/api/vhosts/Test_Virtual_Host