MCPcopy Create free account
hub / github.com/vercel/vercel / acknowledge

Method acknowledge

packages/cli/src/util/dev/queue-broker.ts:316–343  ·  view source on GitHub ↗
(
    messageId: string,
    consumerGroup: string,
    receiptHandle: string
  )

Source from the content-addressed store, hash-verified

314 }
315
316 acknowledge(
317 messageId: string,
318 consumerGroup: string,
319 receiptHandle: string
320 ): boolean {
321 const { deliveries: groupDeliveries, state } = this.findDeliveryState(
322 messageId,
323 consumerGroup
324 );
325 if (!groupDeliveries || !state) return false;
326
327 if (state.receiptHandle && state.receiptHandle !== receiptHandle) {
328 output.debug(
329 `queues: ACK rejected for ${messageId} in group "${consumerGroup}" - receipt handle mismatch`
330 );
331 return false;
332 }
333
334 state.status = 'acked';
335 groupDeliveries.delete(messageId);
336 output.debug(
337 `queues: ACK message ${messageId} in group "${consumerGroup}"`
338 );
339
340 // Clean up message if acked in all groups
341 this.maybeCleanupMessage(messageId);
342 return true;
343 }
344
345 changeVisibility(
346 messageId: string,

Callers 2

DevServerClass · 0.80

Calls 4

findDeliveryStateMethod · 0.95
maybeCleanupMessageMethod · 0.95
debugMethod · 0.80
deleteMethod · 0.45

Tested by

no test coverage detected