class AMQPConsumer extends AMQPWorker {

    public GetResponse consume() {
        try {
            return this.channel.basicGet(this.queueName, true);
        } catch (IOException e) {
            logger.error("Failed to receive message from AMQP; " + this + ". Possible reasons: Queue '" + this.queueName
                    + "' may not have been defined", e);
            throw new ProcessException(e);
        }
    }

      AMQPConsumer(Connection connection, String queueName);

}