class AMQPConsumer extends AMQPWorker {

    @Override
    public void close() throws TimeoutException, IOException {
        closed = true;

        GetResponse lastMessage = null;
        GetResponse response;
        while ((response = responseQueue.poll()) != null) {
            lastMessage = response;
        }

        if (lastMessage != null) {
            getChannel().basicNack(lastMessage.getEnvelope().getDeliveryTag(), true, true);
        }
    }

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

}