Queue Sender
Implementation of IQueueSender bound to a specific queue name. Created by QueueRegistry for each registered queue.
Automatically enriches messages with:
id
timestamp
metadata.locale
// Created by QueueRegistry, not directly instantiatedconst sender = registry.getQueue('notifications-queue')await sender.dispatch({ type: 'email.send', payload: { to: 'user@example.com', subject: 'Hello' }}) Copy
// Created by QueueRegistry, not directly instantiatedconst sender = registry.getQueue('notifications-queue')await sender.dispatch({ type: 'email.send', payload: { to: 'user@example.com', subject: 'Hello' }})
Dispatch a message to this queue.
Message to dispatch (without id/timestamp)
Queue Sender
Implementation of IQueueSender bound to a specific queue name. Created by QueueRegistry for each registered queue.
Automatically enriches messages with:
id: UUID generated via crypto.randomUUID()timestamp: Current time in millisecondsmetadata.locale: Current locale from I18n contextExample