The application whose registry carries the queue
Optionaloptions: QueueHandlerOptions
Which named queue instance to dispatch into
The handler to assign to the Worker's queue export
const app = createApplication({
plugins: [RuntimePlugin({ env }), CloudflarePlugin({ env, queue: { binding: 'JOBS' } })],
});
await app.start();
export default { fetch: app.fetch, queue: createQueueHandler(app) };
At invocation time, when the resolved
token holds an IQueue that is not a WorkersQueue — a memory or
Redis queue has no batch to dispatch and would silently drop the delivery
Builds the handler an application exports as
queue.The queue is resolved from the application's registry rather than passed in, so the processors registered through
IQueue.processanywhere in the application are the processors this handler dispatches into — there is only ever one instance.Resolution is lazy: the token is read on each invocation, not when this factory runs, so the export can be built before
app.start()has registered anything.