Skip to content

Commit 6f90ef0

Browse files
author
Steve Powell
committed
Add message to channel.close().
1 parent 5a2bcc4 commit 6f90ef0

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/com/rabbitmq/client/AlreadyClosedException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
package com.rabbitmq.client;
1919

20-
/*
20+
/**
2121
* Thrown when application tries to perform an action on connection/channel
2222
* which was already closed
2323
*/

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ protected void handleChannelKiller(Channel channel, Throwable exception, String
6565
+ channel + ":");
6666
exception.printStackTrace();
6767
try {
68-
channel.close();
68+
channel.close(AMQP.REPLY_SUCCESS, "Closed due to exception from " + what);
6969
} catch (AlreadyClosedException ace) {
7070
// noop
7171
} catch (IOException ioe) {

0 commit comments

Comments
 (0)