Class SQSHandler

Hierarchy

BaseSQS
- SQSHandler

Index

Constructors

Properties

_name client clientOptions messageTranslator pollingWaitTimeMs provider signalStop started

Methods

callPoll handle poll processMessage queueUrl start stop

Constructors

constructor

new SQSHandler(queueName: string, clientOptions: SQSClientOptions): SQSHandler
Parameters
- queueName: string
- clientOptions: SQSClientOptions
Returns SQSHandler
Overrides BaseSQS.constructor
- Defined in src/ext/sqs/handlers.ts:16

Properties

`Readonly` _name

_name: any = ...

client

client: SQSClient

clientOptions

clientOptions: SQSClientOptions

messageTranslator

messageTranslator: AbstractMessageTranslator

pollingWaitTimeMs

pollingWaitTimeMs: number

provider

provider: SQSProvider

signalStop

signalStop: boolean

started

started: boolean

Methods

callPoll

callPoll(): Promise<void>
Returns Promise<void>
- Defined in src/ext/sqs/handlers.ts:97

handle

handle(_content: object, _metada: object): Promise<boolean>
Parameters
- _content: object
- _metada: object
Returns Promise<boolean>
- Defined in src/ext/sqs/handlers.ts:109

poll

poll(): Promise<void>
Returns Promise<void>
- Defined in src/ext/sqs/handlers.ts:72

processMessage

processMessage(message: any): Promise<void>
Parameters
- message: any
Returns Promise<void>
- Defined in src/ext/sqs/handlers.ts:46

queueUrl

queueUrl(queueName: string): Promise<string>
Parameters
- queueName: string
Returns Promise<string>
Inherited from BaseSQS.queueUrl
- Defined in src/ext/sqs/base.ts:25

start

start(): void
Returns void
- Defined in src/ext/sqs/handlers.ts:35

stop

stop(): Promise<void>
Returns Promise<void>
Overrides BaseSQS.stop
- Defined in src/ext/sqs/handlers.ts:24