We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d156e51 commit de92be3Copy full SHA for de92be3
src/com/rabbitmq/client/impl/AMQConnection.java
@@ -585,14 +585,13 @@ public void shutdown(Object reason,
585
try {
586
synchronized (this) {
587
ensureIsOpen(); // invariant: we should never be shut down more than once per instance
588
- _shutdownCause = new ShutdownSignalException(true,
+ ShutdownSignalException sse = new ShutdownSignalException(true,
589
initiatedByApplication,
590
reason, this);
591
+ sse.initCause(cause);
592
+ _shutdownCause = sse;
593
}
594
- if (cause != null) {
- _shutdownCause.initCause(cause);
595
- }
596
_channel0.processShutdownSignal(_shutdownCause);
597
} catch (AlreadyClosedException ace) {
598
if (initiatedByApplication)
0 commit comments