Constructors
constructor
-
Parameters
-
__namedParameters: object
-
batchSize: 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10
-
handleMessage: function
-
- (message: Message): Promise<void>
-
Parameters
Returns Promise<void>
-
logger: Logger
-
queueUrl: string
-
shouldContinue: function
-
sqs: SQS
-
stopWhenEmpty: boolean
-
waitTimeSeconds: number
Properties
Private logger
logger: Logger
Private queueUrl
queueUrl: string
Private stopWhenEmpty
stopWhenEmpty: boolean
Private waitTimeSeconds
waitTimeSeconds: number
Methods
Private deleteMessages
- deleteMessages(messages: Message[]): Promise<void>
-
Parameters
Returns Promise<void>
Private poll
- poll(): Promise<Message[]>
-
Returns Promise<Message[]>
Private processMessages
- processMessages(messages: Message[]): Promise<void>
-
Parameters
Returns Promise<void>