class AmqpMessageQueue
implements MessageQueue
A message queue that uses AMQP.
new
AmqpMessageQueue(connection: Connection,options?: AmqpMessageQueueOptions,)
Creates a new AmqpMessageQueue
.
enqueue(message: any,options?: MessageQueueEnqueueOptions,): Promise<void>
listen(handler: (message: any) => void | Promise<void>,options?: MessageQueueListenOptions,): Promise<void>