skif48 / nabbitmq Goto Github PK

origin issue #3
@marcio199226 comment:

I have used a custom setup function

  consumerFactory.setCustomSetupFunction(async (connection) => {
    const channel = await connection.createChannel();
    await channel.assertExchange('exchange', 'topic', { durable: true });
    const queueMetadata = await channel.assertQueue('input', {
      durable: true,
      maxPriority: 10
    });

    await channel.bindQueue(queueMetadata.queue, 'exchange', 'account.*');
    await channel.prefetch(1);

    return {channel, prefetch: 1, autoAck: false, queue: 'input'};
  });

And after consuming some message, message.fields.routingKey returns my queue name "input" insteaf of currently messgae routingKey

I have used 0.1.2v

Best regards

Hi thanks for this awesome.

I have a question because i noticed that when I publish a new message to an queue that does not exists that queue is not created itself at the first message delivered so i have to create them manually from rabbitmq dashobard.

Is this the desired behaviour, isn't it??

P.S might you explain me what is for the publisherConfirms option?

Hi,

When i tried to add a vhost to my connection string the connection fails with the following error:

Error: Error while connecting to RabbitMQ: Expected ConnectionOpenOk; got

This is my connection string:
amqp://guest:guest@localhost:5672/vhostname

I havae tried setting connection options through setOptions resulting with the same error reported above:

  connectionFactory.setOptions({
    username: 'guest',
    password: 'guest',
    hostname: 'localhost',
    port: '5672',
    vhost: '/vhostname',
    protocol: 'amqp'
  })

I followed this spec https://www.rabbitmq.com/uri-spec.html.

Thanks in advance for any replies.