Class SqsAdapter

Amazon Web Services SQS adapter utilizing the official SDK V3.

Hierarchy (View Summary)

AbstractQueueAdapter
- SqsAdapter

Index

Constructors

Properties

_client _logger _params

Methods

Constructors

constructor

new SqsAdapter(params: QueueParameters): SqsAdapter
Parameters
- params: QueueParameters
Returns SqsAdapter
Overrides AbstractQueueAdapter.constructor
- Defined in queue-aws/src/SqsAdapter.ts:14

Properties

`Protected`_client

_client: any

`Protected`_logger

_logger: any

`Protected`_params

_params: QueueParameters

Methods

listen

listen(topic: string, handler: Function, params?: any): Promise<void>
Listen to a topic
Parameters
- topic: string
- handler: Function
- Optionalparams: any
Returns Promise<void>
Overrides AbstractQueueAdapter.listen
- Defined in queue-aws/src/SqsAdapter.ts:72

send

send(data: any, topic: string): Promise<string>
Dispatches the AWS SQS SendMessageCommand.
Parameters
- data: any
  Payload.
- topic: string
  Partial Queue URL / Queue name.
Returns Promise<string>
The newly returned MessageId.
Overrides AbstractQueueAdapter.send
- Defined in queue-aws/src/SqsAdapter.ts:48