Stop message consumption from a queue.
The operation is asynchronous. When consumption is stopped, you can also be notified via {@link RabbitMQConsumer#endHandler}
Stop message consumption from a queue.
The operation is asynchronous. When consumption is stopped, you can also be notified via {@link RabbitMQConsumer#endHandler}
Set an end handler. Once the stream has canceled successfully, the handler will be called.
Set an exception handler on the read stream.
Fetch the specified amount of elements. If the ReadStream has been paused, reading will
recommence with the specified amount of items, otherwise the specified amount will
be added to the current stream demand.
Set a message handler. As message appear in a queue, the handler will be called with the message.
Return true if cancel() has been called.
Pause the stream of incoming messages from queue.
The messages will continue to arrive, but they will be stored in a internal queue. If the queue size would exceed the limit provided by , then incoming messages will be discarded.
Resume reading from a queue. Flushes internal queue.
Set the name of the queue. This method is typically only required during a connectionEstablishedCallback when the queue name has changed.
Generated using TypeDoc
A stream of messages from a rabbitmq queue.