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)
526526 if (method instanceof AMQP .Connection .CloseOk ) {
527527 // It's our final "RPC". Time to shut down.
528528 _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.
532532 return _channel0 ._activeRpc == null ;
533533 } else {
534534 // Ignore all others.
Original file line number Diff line number Diff line change @@ -36,6 +36,8 @@ public void testCloseOKNormallyReceived() throws Exception{
3636 assertTrue (connection .hadValidShutdown ());
3737 }
3838
39+ // The thrown runtime exception should get intercepted by the
40+ // consumer exception handler, and result in a clean shut down.
3941 public void testCloseWithFaultyConsumer () throws Exception {
4042 SpecialConnection connection = new SpecialConnection ();
4143 Channel channel = connection .createChannel ();
You can’t perform that action at this time.
0 commit comments