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 9b95d4a commit dd7019cCopy full SHA for dd7019c
src/com/rabbitmq/client/impl/AMQConnection.java
@@ -529,7 +529,7 @@ private class MainLoop implements Runnable {
529
* Continues running until the "running" flag is set false by
530
* shutdown().
531
*/
532
- @Override public void run() {
+ public void run() {
533
try {
534
while (_running) {
535
Frame frame = _frameHandler.readFrame();
@@ -679,7 +679,7 @@ public SocketCloseWait(ShutdownSignalException sse) {
679
cause = sse;
680
}
681
682
683
684
_appContinuation.uninterruptibleGet();
685
} finally {
0 commit comments