diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-12 17:40:36 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-12 17:40:36 +0200 |
commit | 5b1b4a71b2c70db1f8df3266b82dc40eab99953f (patch) | |
tree | 59edea0a118b7e718a6f1408baa52c1ee533a9e9 /documentapi | |
parent | 7f83b13ecb8ba0721c591f8bb6b82512021ad29c (diff) |
Avoid '*' imports.
Diffstat (limited to 'documentapi')
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java | 33 |
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; } |