Class SQSHandler

Hierarchy

BaseSQS
- SQSHandler

Index

Constructors

Properties

client clientOptions messageTranslator pollingWaitTimeMs provider 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:13

Properties

client

client: SQSClient

clientOptions

clientOptions: SQSClientOptions

messageTranslator

messageTranslator: AbstractMessageTranslator

pollingWaitTimeMs

pollingWaitTimeMs: number

provider

provider: SQSProvider

started

started: boolean

Methods

callPoll

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

handle

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

poll

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

processMessage

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

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:20

stop

stop(): void
Returns void
Overrides BaseSQS.stop
- Defined in src/ext/sqs/handlers.ts:28