Skip to content

Commit 9a21229

Browse files
author
Alexandru Scvortov
committed
consumer is now printed
1 parent c7a90be commit 9a21229

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/com/rabbitmq/client/impl/DefaultExceptionHandler.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,10 +56,11 @@ public void handleFlowListenerException(Channel channel, Throwable exception) {
5656
}
5757

5858
public void handleConsumerException(Channel channel, Throwable exception,
59-
Consumer _consumer, String consumerTag,
59+
Consumer consumer, String consumerTag,
6060
String methodName)
6161
{
62-
handleChannelKiller(channel, exception, "Consumer " + consumerTag
62+
handleChannelKiller(channel, exception, "Consumer " + consumer
63+
+ " (" + consumerTag + ")"
6364
+ " method " + methodName
6465
+ " for channel " + channel);
6566
}

0 commit comments

Comments
 (0)