summaryrefslogtreecommitdiffstats
path: root/documentapi/src
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-12 17:40:36 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-12 17:40:36 +0200
commit5b1b4a71b2c70db1f8df3266b82dc40eab99953f (patch)
tree59edea0a118b7e718a6f1408baa52c1ee533a9e9 /documentapi/src
parent7f83b13ecb8ba0721c591f8bb6b82512021ad29c (diff)
Avoid '*' imports.
Diffstat (limited to 'documentapi/src')
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java33
1 files changed, 28 insertions, 5 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 8d989f51de6..aa422c2ad46 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
@@ -4,12 +4,35 @@ package com.yahoo.documentapi.messagebus;
import com.yahoo.document.BucketId;
import com.yahoo.document.BucketIdFactory;
import com.yahoo.document.select.parser.ParseException;
-import com.yahoo.documentapi.*;
-import com.yahoo.documentapi.messagebus.protocol.*;
+import com.yahoo.documentapi.AckToken;
+import com.yahoo.documentapi.ProgressToken;
+import com.yahoo.documentapi.VisitorControlHandler;
+import com.yahoo.documentapi.VisitorDataQueue;
+import com.yahoo.documentapi.VisitorIterator;
+import com.yahoo.documentapi.VisitorParameters;
+import com.yahoo.documentapi.VisitorResponse;
+import com.yahoo.documentapi.VisitorSession;
+import com.yahoo.documentapi.messagebus.protocol.CreateVisitorMessage;
+import com.yahoo.documentapi.messagebus.protocol.CreateVisitorReply;
+import com.yahoo.documentapi.messagebus.protocol.DocumentMessage;
+import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
+import com.yahoo.documentapi.messagebus.protocol.VisitorInfoMessage;
+import com.yahoo.documentapi.messagebus.protocol.WrongDistributionReply;
import com.yahoo.log.LogLevel;
-import com.yahoo.messagebus.*;
+import com.yahoo.messagebus.DestinationSession;
+import com.yahoo.messagebus.DestinationSessionParams;
+import com.yahoo.messagebus.DynamicThrottlePolicy;
import com.yahoo.messagebus.Error;
+import com.yahoo.messagebus.ErrorCode;
+import com.yahoo.messagebus.Message;
+import com.yahoo.messagebus.MessageBus;
+import com.yahoo.messagebus.MessageHandler;
+import com.yahoo.messagebus.Reply;
+import com.yahoo.messagebus.ReplyHandler;
import com.yahoo.messagebus.Result;
+import com.yahoo.messagebus.SourceSession;
+import com.yahoo.messagebus.SourceSessionParams;
+import com.yahoo.messagebus.Trace;
import com.yahoo.messagebus.routing.RoutingTable;
import com.yahoo.vdslib.VisitorStatistics;
import com.yahoo.vdslib.state.ClusterState;
@@ -574,7 +597,7 @@ public class MessageBusVisitorSession implements VisitorSession {
private final long messageTimeoutMs;
- public SendCreateVisitorsTask(long messageTimeoutMs) {
+ SendCreateVisitorsTask(long messageTimeoutMs) {
this.messageTimeoutMs = messageTimeoutMs;
}
@@ -687,7 +710,7 @@ public class MessageBusVisitorSession implements VisitorSession {
private class HandleReplyTask implements Runnable {
private Reply reply;
- public HandleReplyTask(Reply reply) {
+ HandleReplyTask(Reply reply) {
this.reply = reply;
}