QueueClient

module:queue. QueueClient

Base class for the queue clients, implements queue protocol in the same class, not supported methods just do nothing without raising any errors

Constructor

new QueueClient()

Methods

channel()

Description:

  • Return a subscription channel from the given name or options, the same client can support multiple subscriptions, additional subscriptions are specified by appending #channel to the options.queueName, default is to use the primary queue name. Consumer name if present is stripped off.

monitor()

Description:

  • Queue monitor or cleanup service, when poller is involved this will be started and can be used for cleaning up stale messages or other maintainence work the requires.

schedule()

Description:

  • Schedule next poller iteration immediately or after timeout, check configured polling rate, make sure it polls no more than configured number of times per second. If not ready then keep polling until the ready signal is sent. Two events can be used for back pressure support: pause and unpause to stop/restart queue processing