diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java index 4c3fde55f9..2ce488f00d 100644 --- a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java +++ b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java @@ -596,7 +596,7 @@ public void removeRecoveryListener(RecoveryListener listener) { public void automaticallyRecover(AutorecoveringConnection connection, Connection connDelegate) throws IOException { RecoveryAwareChannelN defunctChannel = this.delegate; this.connection = connection; - + final RecoveryAwareChannelN newChannel = (RecoveryAwareChannelN) connDelegate.createChannel(this.getChannelNumber()); if (newChannel == null) throw new IOException("Failed to create new channel for channel number=" + this.getChannelNumber() + " during recovery"); @@ -736,4 +736,9 @@ void updateConsumerTag(String tag, String newTag) { } } + @Override + public String toString() { + return this.delegate.toString(); + } + }