amqplib

amqplib copied to clipboard

"Frame size exceeds frame max" while trying to connect

5

I'm facing this weird error while trying to connect to the rabbitmq client hosted on a separate server ``` Frame size exceeds frame max at parseFrame (/node_modules/amqplib/lib/frame.js:55:13) at Connection.C.recvFrame (/node_modules/amqplib/lib/connection.js:621:15)...

fareed945

Replace url-parse lib with native URL interface

6

Engine specified to node >= 10. Should be no need for a lib to polyfill the `URL` interface or implement the legacy `url.parse` in a browser environment.

jonaswalden

classify callback model

1

Only transformed the prototypes to classes and removed inherit

jimmywarting

Introduce post-connection timeout setting

1

Currently, the timeout for the underlying socket is reset to `0` after a successful connection. This can lead to promises hanging indefinitely / callbacks not being invoked in case the...

hardcodet

connection.close causes process to die and error is uncatchable

16

Hi there. This is in response to a reported error in servicebus, which uses amqplib (https://github.com/mateodelnorte/servicebus/issues/93). Issue: Exiting RabbitMQ causes client code to exit without error. connection.close does fire, but...

mateodelnorte

add property to Object causes runtime error and close connection

4

// output obama { Error: read ECONNRESET at TCP.onread (net.js:660:25) cause: { Error: read ECONNRESET at TCP.onread (net.js:660:25) errno: 'ECONNRESET', code: 'ECONNRESET', syscall: 'read' }, isOperational: true, errno: 'ECONNRESET', code:...

alexaleluia12

Add example for RabbitMQ stream queues

2

It shows how to use the stream queue with the AMQP client. See: - https://www.rabbitmq.com/stream.html - https://blog.rabbitmq.com/posts/2021/07/rabbitmq-streams-overview

Gsantomaggio

Race condition when acking and closing connection

7

I'm experiencing a race condition which doesn't allow me to graceful shutdown my service correctly. My worker pulls from the queue and starts doing long-running jobs. When kubernetes sends the...

fenos

I've added a GitHub action for automatically publishing releases to npm. The envisioned workflow is as follows... 1. Work normally, merging PRs, until ready to release etc 2. Check that...

cressie176

feat: getCh function to return channel ID

7

This getter is to return ch value for better channel resource management by users.

sshtel