import { E as EventBus, R as RabbitMQConfig, S as StreamOptions } from '../kafka-Cf-TUJgv.js';
export { a as KafkaConfig, K as KafkaEventBus, k as kafkaConfigPipe, r as rabbitmqConfigPipe } from '../kafka-Cf-TUJgv.js';
import { E as Events } from '../overrides-6Hxg764S.js';
import 'valleyed';

declare class RabbitMQEventBus extends EventBus {
    #private;
    constructor(config: RabbitMQConfig);
    createStream<Event extends Events[keyof Events]>(topicName: Event['topic'], options?: Partial<StreamOptions>): {
        publish: (data: Event["data"]) => Promise<boolean>;
        subscribe: (onMessage: (data: Event["data"]) => Promise<void>) => Promise<void>;
    };
}

export { EventBus, RabbitMQConfig, RabbitMQEventBus, StreamOptions };