Class QueueManager

Queue Manager

Singleton service for processing queue message batches. Routes messages to consumers based on message type.

Message Routing:

Consumers declare message types they handle (e.g., ['email.send'])
When a message arrives, consumers matching the message type are invoked
A consumer can handle messages from ANY queue (routing is by type, not queue)

Note: For sending messages to queues, use IQueueSender instances obtained via @InjectQueue('queue-name') or module bindings.

Example: Processing a queue batch

// In Cloudflare Worker queue handler
await queueManager.processBatch('notifications-queue', batch)

Index

Constructors

Methods

Constructors

constructor

new QueueManager(registry: ConsumerRegistry): QueueManager
Parameters
- registry: ConsumerRegistry
Returns QueueManager
- Defined in packages/core/src/queue/queue-manager.ts:29

Methods

processBatch

processBatch(_queueName: string, batch: MessageBatch): Promise<void>
Process a batch of queue messages

Routes messages to registered consumers based on message type. Uses ConsumerRegistry to find matching consumers.
Parameters
- _queueName: string
  Name of the queue (for logging, not used for routing)
- batch: MessageBatch
  Batch of messages from Cloudflare Queue
Returns Promise<void>
- Defined in packages/core/src/queue/queue-manager.ts:42