(receiptHandle: string, delayed?: boolean)
| 51 | } |
| 52 | |
| 53 | const removeFromQueue = (receiptHandle: string, delayed?: boolean): Promise<void> => { |
| 54 | const params: SqsDeleteMessageRequest = { |
| 55 | QueueUrl: delayed ? SQS_CONFIG.nodejsWorkerDelayableQueue : SQS_CONFIG.nodejsWorkerQueue, |
| 56 | ReceiptHandle: receiptHandle, |
| 57 | } |
| 58 | |
| 59 | return deleteMessage(SQS_CLIENT(), params) |
| 60 | } |
| 61 | |
| 62 | async function handleDelayedMessages() { |
| 63 | const delayedHandlerLogger = getChildLogger('delayedMessages', serviceLogger, { |
no test coverage detected