class AmqpConsumer extends Consumer {

    public Properties getTransportProperties() {
        return transportProperties;
    }

    public  AmqpConsumer(ChannelHandlerContext ctx,
                        Broker broker,
                        AmqpChannel channel,
                        String queueName,
                        ShortString consumerTag,
                        boolean isExclusive);

}