Class PubSubQueueAdapter

Google Cloud Platform Pub/Sub compatible queue adapter interface.

Hierarchy (View Summary)

AbstractQueueAdapter
- PubSubQueueAdapter

Index

Constructors

Properties

_client _params

Methods

Constructors

constructor

new PubSubQueueAdapter(params: QueueParameters): PubSubQueueAdapter
Parameters
- params: QueueParameters
Returns PubSubQueueAdapter
Overrides AbstractQueueAdapter.constructor
- Defined in queue-gcp/src/GcpPubsubAdapter.ts:9

Properties

`Protected`_client

_client: any

`Protected`_params

_params: QueueParameters

Methods

listen

listen(topic: string): any
Hooks onto the onPublish listener system for internal pub/sub logic tracking.
Parameters
- topic: string
  Destination topic.
Returns any
The GCP listener handler loop.
Overrides AbstractQueueAdapter.listen
- Defined in queue-gcp/src/GcpPubsubAdapter.ts:41

send

send(data: any, topic: string): Promise<string>
Publishes data buffer as a Pub/Sub topic push.
Parameters
- data: any
  The data payload.
- topic: string
  The GCP Topic identifier.
Returns Promise<string>
GCP topic tracking message ID.
Overrides AbstractQueueAdapter.send
- Defined in queue-gcp/src/GcpPubsubAdapter.ts:26