import amqp from 'amqplib' ; import { Options , Replies } from 'amqplib/properties' ; import { AmqpOriginalConsumerWrapper } from '../../wrapper/amqp-original-consumer-wrapper' ; export interface AmqpMessageInterface { sendMessageToExchange ( exchangeName , key , content , options ? ) : Promise < boolean > ; sendMessageToQueue ( queueName , content , options ? ) : Promise < boolean > ; consume ( queue , processor , options ? ) : AmqpOriginalConsumerWrapper ; killConsume ( consumeTag ) : Promise < boolean > ; getCurrentMessage ( queueName , options ? ) : Promise < false | amqp . GetMessage > ; ackMessage ( message , allUp ? ) : Promise < void > ; ackAllMessage ( ) : Promise < void > ; rejectMessage ( message , allUp ? , reQueue ? ) : Promise < void > ; nackAllMessage ( reQueue ? ) : Promise < void > ; setPrefetchCount ( count , global ? ) : Promise < Replies . Empty > ; recover ( ) : Promise < Replies . Empty > ; }