import { AbstractClientService } from '@joktec/core';
import { ChannelModel } from 'amqplib';
import { RabbitAssertExchange, RabbitAssertExchangeOptions, RabbitAssertOptions, RabbitAssertQueue, RabbitAutoBindingRegistry, RabbitBaseOptions, RabbitBindingOptions, RabbitConsumeOptions, RabbitEmpty, RabbitExchangeType, RabbitMessage, RabbitProduceOptions, RabbitProduceResult, RabbitPublishOptions, RabbitPublishResult, RabbitPurgeQueue, RabbitRejectOptions } from './models';
import { RabbitClient } from './rabbit.client';
import { RabbitConfig } from './rabbit.config';
import { RabbitMetricService } from './rabbit.metric';
export declare class RabbitService extends AbstractClientService<RabbitConfig, ChannelModel> implements RabbitClient {
    private autoBindingRegistry;
    private rabbitMetricService;
    private props;
    constructor(autoBindingRegistry: RabbitAutoBindingRegistry, rabbitMetricService: RabbitMetricService);
    protected init(config: RabbitConfig): Promise<ChannelModel>;
    protected start(client: ChannelModel, conId?: string): Promise<void>;
    protected stop(client: ChannelModel, conId?: string): Promise<void>;
    private createChannel;
    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>, opts?: RabbitConsumeOptions, conId?: string): Promise<void>;
    commit(msg: RabbitMessage, opts?: RabbitBaseOptions, conId?: string): Promise<void>;
    reject(msg: RabbitMessage, opts?: RabbitRejectOptions, conId?: string): Promise<void>;
    assert(name: string, opts?: RabbitAssertOptions, conId?: string): Promise<RabbitAssertQueue>;
    assertExchange(name: string, type?: RabbitExchangeType | string, opts?: RabbitAssertExchangeOptions, conId?: string): Promise<RabbitAssertExchange>;
    check(name: string, opts?: RabbitBaseOptions, conId?: string): Promise<RabbitAssertQueue>;
    purge(name: string, opts?: RabbitBaseOptions, conId?: string): Promise<RabbitPurgeQueue>;
    cancel(consumerTag: string, opts?: RabbitBaseOptions, conId?: string): Promise<RabbitEmpty>;
    binding(queue: string, exchange: {
        exchangeKey: string;
        routingKey: string;
        type?: RabbitExchangeType | string;
    }, opts?: RabbitBindingOptions, conId?: string): Promise<RabbitEmpty>;
}
//# sourceMappingURL=rabbit.service.d.ts.map