diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-05 17:09:29 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-07-05 17:09:29 +0200 |
commit | 76019c70d1c41a16ee2fb6af56bc35f4cd52b667 (patch) | |
tree | b7211f046f4d846b66149decf58bfa56ce6dbb5d /documentapi | |
parent | 93eb6426e14b015052c9b885ebd280aac9e545cb (diff) | |
parent | a97c8389d4ab11cacc1c149f7eb0534edc4d4faa (diff) |
Merge pull request #23368 from vespa-engine/revert-23361-balder/remove-long-gone-compression-option
Revert "GC long gone config"
Diffstat (limited to 'documentapi')
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java index 1c729008e2c..3607f652a51 100755 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java @@ -230,6 +230,7 @@ public class MessageBusVisitorSession implements VisitorSession { @Override public Sender createSender(ReplyHandler replyHandler, VisitorParameters visitorParameters) { + messageBus.setMaxPendingCount(0); SourceSessionParams sessionParams = createSourceSessionParams(visitorParameters); return new MessageBusSender(messageBus.createSourceSession(replyHandler, sessionParams)); } @@ -307,7 +308,7 @@ public class MessageBusVisitorSession implements VisitorSession { private static final Logger log = Logger.getLogger(MessageBusVisitorSession.class.getName()); - private static final AtomicLong sessionCounter = new AtomicLong(0); + private static AtomicLong sessionCounter = new AtomicLong(0); private static long getNextSessionId() { return sessionCounter.incrementAndGet(); } @@ -335,7 +336,7 @@ public class MessageBusVisitorSession implements VisitorSession { private boolean done = false; private boolean destroying = false; // For testing and sanity checking private final Object completionMonitor = new Object(); - private final Trace trace; + private Trace trace; /** * We keep our own track of pending messages since the sender's pending * count cannot be relied on in an async task execution context. This |