File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
src/com/rabbitmq/client/impl
test/src/com/rabbitmq/client/test Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -526,9 +526,9 @@ public boolean processControlCommand(Command c)
526
526
if (method instanceof AMQP .Connection .CloseOk ) {
527
527
// It's our final "RPC". Time to shut down.
528
528
_running = false ;
529
- // If this was called from within the MainLoop we
530
- // may not have a continuation to return to, so we
531
- // treat this as processed in that case.
529
+ // If Close was sent from within the MainLoop we
530
+ // will not have a continuation to return to, so
531
+ // we treat this as processed in that case.
532
532
return _channel0 ._activeRpc == null ;
533
533
} else {
534
534
// Ignore all others.
Original file line number Diff line number Diff line change @@ -36,6 +36,8 @@ public void testCloseOKNormallyReceived() throws Exception{
36
36
assertTrue (connection .hadValidShutdown ());
37
37
}
38
38
39
+ // The thrown runtime exception should get intercepted by the
40
+ // consumer exception handler, and result in a clean shut down.
39
41
public void testCloseWithFaultyConsumer () throws Exception {
40
42
SpecialConnection connection = new SpecialConnection ();
41
43
Channel channel = connection .createChannel ();
You can’t perform that action at this time.
0 commit comments