summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-10-10 14:06:24 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2023-10-10 14:06:24 +0200
commit63aeee559a51d872f8f7d83d63fbcbff928b70ee (patch)
tree27cc91dc1c478126aef3415a8a3fbb96087db079 /messagebus
parent888a2e3fb78955580c4bdfccb722f631da28c997 (diff)
Initialize explicit to Bollean.FALSE
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java4
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 {