Queue Registry
Request-scoped factory service for creating QueueSender instances. Caches senders per queue name within the request scope.
This service is used internally by QueueModule.registerQueue() to provide IQueueSender instances for each registered queue.
Why request-scoped?
// Used internally by QueueModule.registerQueue()QueueModule.registerQueue('notifications-queue')// The module creates a factory provider:{ provide: 'notifications-queue', useFactory: (registry: QueueRegistry) => registry.getQueue('notifications-queue'), inject: [QUEUE_TOKENS.QueueRegistry],} Copy
// Used internally by QueueModule.registerQueue()QueueModule.registerQueue('notifications-queue')// The module creates a factory provider:{ provide: 'notifications-queue', useFactory: (registry: QueueRegistry) => registry.getQueue('notifications-queue'), inject: [QUEUE_TOKENS.QueueRegistry],}
Get or create a QueueSender for the specified queue name.
Senders are cached per queue name within the request scope.
The queue name to get a sender for
QueueSender bound to the specified queue
Queue Registry
Request-scoped factory service for creating QueueSender instances. Caches senders per queue name within the request scope.
This service is used internally by QueueModule.registerQueue() to provide IQueueSender instances for each registered queue.
Why request-scoped?
Example