summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-10-10 13:09:57 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2023-10-10 13:09:57 +0200
commit888a2e3fb78955580c4bdfccb722f631da28c997 (patch)
tree9e4a17fe7c26441ef5e67748c5a8189b4a2ead55 /messagebus
parent3f4b963ea783c6153542aadfb47139c1dbc888aa (diff)
Use Boolean instead of Object
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java11
1 files changed, 5 insertions, 6 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java
index 671e59dc7c9..f19d33c87b8 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java
@@ -21,8 +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 Object BUSY = new Object();
- private final static ThreadLocal<Object> isSending = new ThreadLocal<>();
+ private final static ThreadLocal<Boolean> isSending = new ThreadLocal<>();
/**
* Constructs a new sequencer on top of the given async sender.
@@ -163,15 +162,15 @@ public class Sequencer implements MessageHandler, ReplyHandler {
}
}
if (msg != null) {
- Object alreadySending = isSending.get();
- if ((alreadySending == BUSY) && (msn != null)) {
+ Boolean alreadySending = isSending.get();
+ if ((alreadySending == Boolean.TRUE) && (msn != null)) {
// Dispatch in another thread to break possibly very long recursion.
msn.enqueue(new SequencedSendTask(msg));
} else {
- isSending.set(BUSY);
+ isSending.set(Boolean.TRUE);
sequencedSend(msg);
}
- isSending.set(null);
+ isSending.set(Boolean.FALSE);
}
}