Class SQSHandler

Hierarchy

BaseSQS
- SQSHandler

Index

Constructors

Properties

client clientOptions logger 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:14

Properties

client

client: SQSClient

clientOptions

clientOptions: SQSClientOptions

logger

logger: LoggerService

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

handle

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

poll

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

processMessage

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

queueUrl

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

start

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

stop

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