diff options
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java index f19d33c87b8..228fe320bf7 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java @@ -21,7 +21,7 @@ public class Sequencer implements MessageHandler, ReplyHandler { private final MessageHandler sender; private final Map<Long, Queue<Message>> seqMap = new HashMap<>(); private final Messenger msn; - private final static ThreadLocal<Boolean> isSending = new ThreadLocal<>(); + private final static ThreadLocal<Boolean> isSending = ThreadLocal.withInitial(() -> Boolean.FALSE); /** * Constructs a new sequencer on top of the given async sender. @@ -163,7 +163,7 @@ public class Sequencer implements MessageHandler, ReplyHandler { } if (msg != null) { Boolean alreadySending = isSending.get(); - if ((alreadySending == Boolean.TRUE) && (msn != null)) { + if (alreadySending && (msn != null)) { // Dispatch in another thread to break possibly very long recursion. msn.enqueue(new SequencedSendTask(msg)); } else { |