Class AmqpQueueAdapter

AMQP Protocol compatible adapter (RabbitMQ, etc.) using amqplib.

Hierarchy (View Summary)

AbstractQueueAdapter
- AmqpQueueAdapter

Index

Constructors

Properties

_client _logger _params

Methods

_connect _disconnect listen send

Constructors

constructor

new AmqpQueueAdapter(params: any): AmqpQueueAdapter
Parameters
- params: any
Returns AmqpQueueAdapter
Overrides AbstractQueueAdapter.constructor
- Defined in queue-amqp/src/AmqpQueueAdapter.ts:11

Properties

`Protected`_client

_client: ChannelModel | undefined

`Protected`_logger

_logger: any

`Protected`_params

_params: QueueParameters

Methods

`Protected`_connect

_connect(): Promise<ChannelModel>
Returns Promise<ChannelModel>
- Defined in queue-amqp/src/AmqpQueueAdapter.ts:16

`Protected`_disconnect

_disconnect(): Promise<void>
Returns Promise<void>
- Defined in queue-amqp/src/AmqpQueueAdapter.ts:33

listen

listen(
    topic?: string | undefined,
    messageHandler: Function,
    params?: any,
): Promise<Consume>
Listen to given queue and process messages with messageHandler function
Parameters
- topic: string | undefined = ...
- messageHandler: Function
- Optionalparams: any
Returns Promise<Consume>
Overrides AbstractQueueAdapter.listen
- Defined in queue-amqp/src/AmqpQueueAdapter.ts:68

send

send(data: any, topic: string): Promise<string>
Enqueues data using the active amqplib channel.
Parameters
- data: any
  Raw payload.
- topic: string
  Specific queue name.
Returns Promise<string>
Result string identifier.
Overrides AbstractQueueAdapter.send
- Defined in queue-amqp/src/AmqpQueueAdapter.ts:44