import { Connection } from 'amqplib';
import { MessageTopicPayload } from './MessageTopicPayload';
import { TopicProcessResult } from './TopicProcessResult';
export default function consumeExchange<T>(exchangeName: string, routingKey: string, queueName: string, connection: Connection, onConsume: (payload: MessageTopicPayload<T>) => Promise<TopicProcessResult>): Promise<any>;