tjmehta / amqplib-rpc Goto Github PK

There are applications where an unique connection and channel are used to communicate with a RabbitMQ server.

I measured ~500 ms when creating a connection, ~100 ms creating the channel. Clients could cache the connection and avoid the greater overhead. But still there's a quite large ~100 ms overhead.

It would be really nice if the first parameter of the rpc function were either a connection or a channel. If it is a channel then we probably shouldn't close it at the end of the operation.

What do you think?

Exclusive queue's do not auto-delete when channel is deleted..

Hi. Congratulations by your package.

Can you make definition types for your lib, to I can use on typescript?

Thanks

NPM v3.10.6
Node v6.5.0

npm WARN deprecated [email protected]: 'native-or-bluebird' is deprecated. Please use 'any-promise' instead.

+-- [email protected]
| +-- [email protected]
| | +-- [email protected]
| | +-- [email protected]
| | `-- [email protected]
| |   `-- [email protected]

Provide an option (and better defaults) for naming the reply queues.

Unfortunately, doesn't work with [email protected], because of old when library

TypeError: channel.assertQueue(...).then(...).catch is not a function
    at /Users/pnedelko/projects/elastic/api/node_modules/amqplib-rpc/lib/request.js:99:15
    at Object.then (/Users/pnedelko/projects/elastic/api/node_modules/when/when.js:355:15)
    at /Users/pnedelko/projects/elastic/api/node_modules/when/when.js:253:12
    at /Users/pnedelko/projects/elastic/api/node_modules/when/when.js:417:5
    at Immediate.drainQueue [as _onImmediate] (/Users/pnedelko/projects/elastic/api/node_modules/when/when.js:735:4)
    at tryOnImmediate (timers.js:543:15)
    at processImmediate [as _immediateCallback] (timers.js:523:5)

I am using spring amqp for my service written in Java, and my colleague created a service using nodejs and he is using amqplib-rpc. The problem is when I tried to request from spring amqp to amqplib-rpc it raise an error that "reply() cannot reply to a message without 'correlationId'". It said that spring amqp automatically creates a correlationid. In fact, its ok when I use spring amqp to spring amqp request

Getting this for callback api of amqplib