/**
 * WorkerEventBus - Simplified event bus for worker processes
 *
 * This is a minimal implementation of ExecutionEventBus for workers to publish
 * task events (status updates, messages, artifacts) to AMQP.
 */
import { EventEmitter } from "events";
import { Task, Message, TaskStatusUpdateEvent, TaskArtifactUpdateEvent } from "@a2a-js/sdk";
import { ExecutionEventBus } from "@a2a-js/sdk/server";
import type { AMQPConnection } from "./AMQPConnection.js";
/**
 * Simple event bus for workers to publish events to AMQP
 * Workers don't consume events, only publish them
 */
export declare class WorkerEventBus extends EventEmitter implements ExecutionEventBus {
    private connection;
    private taskId;
    private contextId;
    private logger;
    private isFinished;
    constructor(connection: AMQPConnection, taskId: string, contextId: string);
    /**
     * Publish an event to the AMQP stream
     */
    publish(event: Task | Message | TaskStatusUpdateEvent | TaskArtifactUpdateEvent): void;
    /**
     * Signal that no more events will be published
     */
    finished(): void;
    /**
     * Publish event to AMQP with metadata
     */
    private publishToAMQP;
    /**
     * Generate routing key based on event type
     * Pattern: a2a.{contextId}.{taskId}.{eventKind}
     */
    private getRoutingKey;
}
//# sourceMappingURL=WorkerEventBus.d.ts.map