/** * Worker Process Example - Queuing Architecture * * This worker: * 1. Consumes tasks from the AMQP work queue * 2. Processes one task at a time (sequential processing) * 3. Creates EventBus in publisher mode for each task * 4. Executes the AgentExecutor to process the task * 5. Publishes progress events to the AMQP stream * 6. ACKs the message when complete * * Can run multiple instances of this worker for parallel processing */ export {}; //# sourceMappingURL=worker.d.ts.map