MCPcopy Index your code
hub / github.com/linuxfoundation/crowd.dev / removeFromQueue

Function removeFromQueue

backend/src/bin/nodejs-worker.ts:53–60  ·  view source on GitHub ↗
(receiptHandle: string, delayed?: boolean)

Source from the content-addressed store, hash-verified

51}
52
53const 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
62async function handleDelayedMessages() {
63 const delayedHandlerLogger = getChildLogger('delayedMessages', serviceLogger, {

Callers 2

handleDelayedMessagesFunction · 0.85
processSingleMessageFunction · 0.85

Calls 2

deleteMessageFunction · 0.90
SQS_CLIENTFunction · 0.90

Tested by

no test coverage detected