class AMQPConsumer extends AMQPWorker {

    public GetResponse consume() {
        return responseQueue.poll();
    }

      AMQPConsumer(final Connection connection, final String queueName, final boolean autoAcknowledge);

}