Class AbstractQueueAdapter`Abstract`

Blueprint for Queue messaging adapters (AMQP, SQS, PubSub, etc.).

Hierarchy (View Summary)

AbstractQueueAdapter

Index

Constructors

Properties

_client _params

Methods

Constructors

constructor

new AbstractQueueAdapter(params: QueueParameters): AbstractQueueAdapter
Parameters
- params: QueueParameters
Returns AbstractQueueAdapter
- Defined in queue/src/AbstractQueueAdapter.ts:10

Properties

`Protected`_client

_client: any

`Protected`_params

_params: QueueParameters

Methods

`Abstract`listen

listen(
    topic: string,
    handler: Function,
    params?: { concurrency?: number; gpu?: boolean },
): any
Starts a background listener on a given queue topic.
Parameters
- topic: string
  The queue name.
- handler: Function
  The callback function.
- Optionalparams: { concurrency?: number; gpu?: boolean }
  Execution context options.
Returns any
- Defined in queue/src/AbstractQueueAdapter.ts:30

`Abstract`send

send(data: any, topic: string): Promise<string>
Dispatches a payload into a specified queue or topic.
Parameters
- data: any
  The payload to send.
- topic: string
  The destination topic/queue name.
Returns Promise<string>
The resolved message ID.
- Defined in queue/src/AbstractQueueAdapter.ts:21