diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-10-10 14:06:24 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-10-10 14:06:24 +0200 |
commit | 63aeee559a51d872f8f7d83d63fbcbff928b70ee (patch) | |
tree | 27cc91dc1c478126aef3415a8a3fbb96087db079 /messagebus | |
parent | 888a2e3fb78955580c4bdfccb722f631da28c997 (diff) |
Initialize explicit to Bollean.FALSE
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 { |