summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2018-10-22 09:41:17 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2018-10-22 09:41:17 +0200
commit6e616650a840f03b518c53f85eec5211c72077f9 (patch)
treef2c5908917c7eafb934f2ae1f558fce8a709f7af /messagebus
parent8b5f6ba43fbd8948e241ee8021e375c94638e677 (diff)
return after discard.
Diffstat (limited to 'messagebus')
-rwxr-xr-xmessagebus/src/main/java/com/yahoo/messagebus/Messenger.java1
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));