Returns a stream of publisher's actions. Contains logs about sent messages as items. Any errors the publisher ends up with will be accessible with this stream.
Closes current channel. Every other option on it will result in an error thrown inside the stream.
Returns active channel object of amqplib.
Returns active publisher configs or null, if publisher was set up with a custom setup function
Returns active connection object of amqplib.
Initializes publisher instance and sets up internal RabbitMQ structure either with configs object, or with custom setup function. Prefers function if has both options supplied.
Connection to use to setup internal RabbitMQ structure.
Publishes messages to RabbitMQ.
message to publish in form of Node's Buffer
optional routing key to attach to your message
options to publish with message with. Can be found in amqplib
Reconnects to the server. Retries given or default (infinite) amount of times. Return an observable that completes when connection is established again.
Sets publisher configs. Accessible to users, but should only be used by PublisherFactory.
configs to setup publisher and RabbitMQ with
Sets custom setup function. Accessible to users, but should only be used by PublisherFactory.
function that sets up internal RabbitMQ structure
Generated using TypeDoc
Used for setting up or ensuring required RabbitMQ internal structure and publishing messages.