silent fail on sending message after stopped
This commit is contained in:
parent
1dab218d7e
commit
5ebf63e0de
@ -499,8 +499,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
|
|||||||
|
|
||||||
Uninterruptibles.sleepUninterruptibly(200, TimeUnit.MILLISECONDS);
|
Uninterruptibles.sleepUninterruptibly(200, TimeUnit.MILLISECONDS);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
log.error(t.getMessage());
|
handleException(t);
|
||||||
t.printStackTrace();
|
|
||||||
} finally {
|
} finally {
|
||||||
stopped = true;
|
stopped = true;
|
||||||
UserThread.execute(() -> doShutDown(closeConnectionReason, shutDownCompleteHandler));
|
UserThread.execute(() -> doShutDown(closeConnectionReason, shutDownCompleteHandler));
|
||||||
|
Loading…
Reference in New Issue
Block a user