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.
2 parents d868699 + de92be3 commit fac0a48Copy full SHA for fac0a48
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