import * as valleyed from 'valleyed';
import { E as Events } from '../../../overrides-6Hxg764S.js';
import { EventBus, StreamOptions, Stream } from '../../index.js';

declare const rabbitmqConfigPipe: () => valleyed.Pipe<{
    uri: string;
    eventColumnName: string;
}, {
    uri: string;
    eventColumnName: string;
}>;
declare const RabbitMQEventBus_base: (abstract new (validated: {
    uri: string;
    eventColumnName: string;
}) => EventBus & {
    readonly config: {
        uri: string;
        eventColumnName: string;
    };
}) & {
    readonly Config: {
        uri: string;
        eventColumnName: string;
    };
    create<This extends Function & {
        prototype: any;
    }>(this: This, input: {
        uri: string;
        eventColumnName: string;
    }, ...args: ConstructorParameters<This & (abstract new (...args: any[]) => any)> extends [{
        uri: string;
        eventColumnName: string;
    }, ...infer R] ? R : never): This["prototype"];
};
declare class RabbitMQEventBus extends RabbitMQEventBus_base {
    #private;
    protected constructor(config: typeof RabbitMQEventBus.Config);
    stream<Event extends Events[keyof Events]>(topicName: Event['topic'], options?: Partial<StreamOptions>): Stream<Event['data']>;
}

export { RabbitMQEventBus, rabbitmqConfigPipe };