DefaultQueueBridge

capabilities: QueueBridgeCapabilities

Process-local capability matrix for strict startup validation.

instanceId: string

Runtime instance id for this in-memory bridge instance.

name: "DefaultQueueBridge"

Human-readable bridge name used in diagnostics and metrics.

ack(queueName: string, leaseId: string): Promise<void>

Acknowledge successful processing and remove the leased message.

destroy(): Promise<void>

Release provider resources and stop background bridge activity.

enqueue(options: QueueEnqueueOptions<unknown, unknown>): Promise<QueueEnqueueResult>

Enqueue a queue message and return provider-visible job metadata.

extendLease(queueName: string, leaseId: string, extensionMs: number): Promise<void>

Extend an active lease so long-running work can continue safely.

inspectLeases(_queueName: string, _options?: QueueDeadLetterListOptions): Promise<QueueLeaseInspectionRecord[]>

Inspect active leases when the adapter supports lease diagnostics.

isHealthy(): Promise<boolean>

Returns whether the bridge can currently make progress.

isReady(): Promise<boolean>

Returns whether the bridge has completed startup and can accept calls.

leaseNext(queueName: string, _opts?: QueueLeaseOptions): Promise<QueueLease | undefined>

Lease the next available message for a worker, if one is ready.

metrics(queueName: string): Promise<QueueMetrics>

Return queue-level operational metrics for health and dashboards.

moveToDeadLetter(queueName: string, message: QueueMessage, reason?: string): Promise<void>

Move a message to the dead-letter store with an optional safe reason.

nack(queueName: string, leaseId: string, request: QueueRetryRequest): Promise<void>

Return a leased message to the queue or move it toward dead-letter policy.

peekDeadLetter(queueName: string, options?: QueueDeadLetterListOptions): Promise<QueueMessage[]>

Inspect dead-letter messages without redriving or deleting them.

purgeDeadLetter(queueName: string): Promise<number>

Delete all dead-letter messages for the queue.

redriveDeadLetter(queueName: string, options?: QueueDeadLetterRedriveOptions): Promise<number>

Move dead-letter messages back to the live queue.

start(): Promise<void>

Start the bridge and establish any provider connection needed for work.