rabbus

rabbus copied to clipboard

var exP = this.rabbit.addExchange( exchangeOptions.name, exchangeOptions.type, exchangeOptions, exchangeOptions.connectionName //add );

walkerx

I am trying to use a plugin: https://github.com/rabbitmq/rabbitmq-delayed-message-exchange, to handle delayed message scheduling. This plugin needs custom headers on the message, as well as on the exchange when it is...

jnystrom

I'm going through your library and it's worked great going through the demos. I'm looking at a use case for receiving multiple messages. The use case would be I would...

b3tts32

Prioritizing messages?

2

Hi, I've struggled with getting messages prioritized in RabbitMQ using Rabbus send-receive pattern. I create the exchange like this: ``` 1 'use strict'; 2 var util = require('../util/util'); 3 var...

markohaapala

I would like to use a pattern of dealing with a delayed delivery to a queue, and am wanting to use a dead letter exchange to handle this. Is this...

jnystrom

How do rabbus handle rebuilding back the topology upon reconnection?

8

I'm using `request-respond` pattern in where at some point I `reset` rabbitmq server connection. When I make a `request` I do receive a `respond` but I receive it `twice`. In...

yamii

Wildcards in routingkeys

1

I have still the huge problem using wildcards in routing keys. What I want to archive: I have two subscribers: First one should listen all events in exchange. Second one...

shurik239

Response / Request - creating the Responder without exchange and routingKey not working

2

Hello, In the demo example we supposed to create the response with following options : exchange: "req-res.exchange", queue: { name: "req-res.queue", limit: 1 }, routingKey: "req-res.key" and this is working....

dimaxweb

undefined message is always in `Ready` state

3

I am using request/respond library accidentally I've passed a `undefined` message to the request. The request stayed in `Ready` state and error is not emitted. I'm thinking of trapping undefined...

yamii