First implementation

[marcopiraccini]

First implementation.
This is configured with:

{
    url: 'amqp://localhost',
    generateExchange: true,
    exchanges: [{
       name: 'test-exchange',
       targetUrl: 'http://localhost:3042/target'
   }]
}

[mcollina]

This should also expose routes to publish messages on those exchanges

[mcollina]

Could you add a test with two instances listening to the same exchange and queue? They should deliver the message only once.

[mcollina]

you must consume the incoming body, or you'd wait for the socket to timeout to close it.

[mcollina]

can you also add a schema for the output?

[mcollina]

this is missing the charset. Unfortunately it's needed or it won't work for folks in asia.

[marcopiraccini]

Could you add a test with two instances listening to the same exchange and queue? They should deliver the message only once.

It's already done here: https://github.com/platformatic/rabbitmq-hooks/blob/first-implementation/test/rabbitmq.test.js#L160

[mcollina]

lgtm