aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi/src/main
diff options
context:
space:
mode:
authorArnstein Ressem <aressem@gmail.com>2022-07-05 19:48:26 +0200
committerGitHub <noreply@github.com>2022-07-05 19:48:26 +0200
commit787c43c5361e11fdc9f86ec47a722f3941442837 (patch)
treeb7211f046f4d846b66149decf58bfa56ce6dbb5d /documentapi/src/main
parente9bc0150adc5bb151bba0da69cb28fbe6bda145d (diff)
Revert "Revert "Revert "GC long gone config"""
Diffstat (limited to 'documentapi/src/main')
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java5
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