import { Connection } from 'amqplib';
import { MessageTopicPayload, TopicProcessResult } from '.';
export declare class TopicClient {
    static instance: TopicClient;
    static connection: Connection;
    static init(connection: Connection): TopicClient;
    sendToExchange<T>(exchangeName: string, routingKey: string, message: T): Promise<any>;
    consumeExchange<T>(exchangeName: string, routingKey: string, queueName: string, onConsume: (payload: MessageTopicPayload<T>) => Promise<TopicProcessResult>): Promise<any>;
}
export declare function sendToExchange<T>(exchangeName: string, routingKey: string, message: T, connection: Connection): Promise<any>;
export declare function consumeExchange<T>(exchangeName: string, routingKey: string, queueName: string, connection: Connection, onConsume: (payload: MessageTopicPayload<T>) => Promise<TopicProcessResult>): Promise<any>;