import { Client } from '@joktec/core';
import { ChannelModel, ConfirmChannel } from 'amqplib';
import { RabbitMessage, RabbitConsumeOptions, RabbitProduceOptions, RabbitProduceResult, RabbitPublishOptions, RabbitPublishResult } from './models';
import { RabbitConfig } from './rabbit.config';
export interface RabbitClient extends Client<RabbitConfig, ChannelModel> {
    sendToQueue(queue: string, messages: string[], opts?: RabbitProduceOptions, conId?: string): Promise<RabbitProduceResult>;
    publish(exchange: string, messages: {
        key: string;
        content: string;
    }[], opts?: RabbitPublishOptions, conId?: string): Promise<RabbitPublishResult>;
    consume(queue: string, callback: (msg: RabbitMessage) => Promise<void>, options: RabbitConsumeOptions, conId: string): Promise<void>;
}
export interface RabbitProp {
    channels: {
        [channelKey: string]: ConfirmChannel;
    };
    hooks: {
        [channelKey: string]: ((channel: ConfirmChannel) => Promise<void>)[];
    };
}
//# sourceMappingURL=rabbit.client.d.ts.map