node-amqp- все статьи тега
Как преобразовать буфер сообщений AQMP в объект JSON при использовании node.модуль JS amqp?
Я использую узел.JS amqp модуль для чтения сообщений из очереди. Ниже приведен обратный вызов, который вызывается при наличии сообщения, доступного в очереди: function onMessage(message, headers, deliveryInfo) { console.log(message); //This prints buffer //how to convert message (which I expect to be JSON) into a JSON object. //Also how to get the JSON string from the 'message' which seems to be a buffer } Спасибо. ...
RabbitMQ / AMQP: одна очередь, несколько потребителей для одного сообщения?
Я только начинаю использовать RabbitMQ и AMQP в целом. у меня есть очередь сообщений у меня есть несколько потребителей, которые я хотел бы сделать разные вещи с тот же. большая часть документации RabbitMQ, по-видимому, ориентирована на циклический перебор, т. е. когда одно сообщение потребляется одним потребителем, а нагрузка распределяется между каждым потребителем. Это действительно то поведение, которое я наблюдаю. пример: производитель имеет одну очередь, и отправлять сообщения кажды ...