diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-10-22 09:41:17 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2018-10-22 09:41:17 +0200 |
commit | 6e616650a840f03b518c53f85eec5211c72077f9 (patch) | |
tree | f2c5908917c7eafb934f2ae1f558fce8a709f7af /messagebus | |
parent | 8b5f6ba43fbd8948e241ee8021e375c94638e677 (diff) |
return after discard.
Diffstat (limited to 'messagebus')
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/Messenger.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java index 34a640f3f83..4fb83386231 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java @@ -69,6 +69,7 @@ public class Messenger implements Runnable { public void deliverMessage(final Message msg, final MessageHandler handler) { if (destroyed.get()) { msg.discard(); + return; } try { sendExecutor.execute(new MessageTask(msg, handler)); |