tjmehta / amqplib-rpc Goto Github PK
View Code? Open in Web Editor NEWThin Amplib utils for RabbitMQ RPC in Node.js
License: MIT License
Thin Amplib utils for RabbitMQ RPC in Node.js
License: MIT License
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
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.