Skip to content

Commit

Permalink
Fix reason when creating ShutdownSignalException in handleCancel
Browse files Browse the repository at this point in the history
  • Loading branch information
Dave Stevens committed Jan 27, 2012
1 parent ad1cc7d commit f175d04
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -243,7 +243,7 @@ public void handleCancel(String consumerTag) {
logger.error("Received unexpected cancellation notice for " + BlockingQueueConsumer.this);
}
cancelled.set(true); //we were canceled by the server
shutdown = new ShutdownSignalException(false, false, consumerTag, channel);
shutdown = new ShutdownSignalException(false, false, "Received unexpected cancellation notice for " + BlockingQueueConsumer.this, channel);

// Signal to the container that we have been cancelled
activeObjectCounter.release(BlockingQueueConsumer.this);
Expand Down

0 comments on commit f175d04

Please sign in to comment.