aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-07-05 13:38:22 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2022-07-05 13:38:22 +0200
commitb97e6cbbfac61678d52486d52708c605412e7dd7 (patch)
tree8feb2a74e9c67c6a855583076e6f7e85b8642cb4 /documentapi
parent74b250fbc3966321b5603b79c9fbf66235139fa5 (diff)
GC long gone config
Diffstat (limited to 'documentapi')
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java5
1 files changed, 2 insertions, 3 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 3607f652a51..1c729008e2c 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
@@ -230,7 +230,6 @@ 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));
}
@@ -308,7 +307,7 @@ public class MessageBusVisitorSession implements VisitorSession {
private static final Logger log = Logger.getLogger(MessageBusVisitorSession.class.getName());
- private static AtomicLong sessionCounter = new AtomicLong(0);
+ private static final AtomicLong sessionCounter = new AtomicLong(0);
private static long getNextSessionId() {
return sessionCounter.incrementAndGet();
}
@@ -336,7 +335,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 Trace trace;
+ private final 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