Class SQSProvider

Hierarchy

AbstractProvider
- SQSProvider

Index

Constructors

Properties

client clientOptions queueName

Methods

confirmMessage fetchMessages messageNotProcessed stop

Constructors

constructor

new SQSProvider(queueName: string, clientOptions: SQSClientOptions): SQSProvider
Parameters
- queueName: string
- clientOptions: SQSClientOptions
Returns SQSProvider
Overrides AbstractProvider.constructor
- Defined in src/ext/sqs/providers.ts:21

Properties

client

client: BaseSQS

clientOptions

clientOptions: SQSClientOptions

queueName

queueName: string

Methods

confirmMessage

confirmMessage(message: object): Promise<void | DeleteMessageCommandOutput>
Parameters
- message: object
Returns Promise<void | DeleteMessageCommandOutput>
Overrides AbstractProvider.confirmMessage
- Defined in src/ext/sqs/providers.ts:28

fetchMessages

fetchMessages(): Promise<object[]>
Returns Promise<object[]>
Overrides AbstractProvider.fetchMessages
- Defined in src/ext/sqs/providers.ts:76

messageNotProcessed

messageNotProcessed(message: object): Promise<void | ChangeMessageVisibilityCommandOutput>
Parameters
- message: object
Returns Promise<void | ChangeMessageVisibilityCommandOutput>
Overrides AbstractProvider.messageNotProcessed
- Defined in src/ext/sqs/providers.ts:46

stop

stop(): void
Returns void
Overrides AbstractProvider.stop
- Defined in src/ext/sqs/providers.ts:93