From 5b1b4a71b2c70db1f8df3266b82dc40eab99953f Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Fri, 12 Apr 2019 17:40:36 +0200 Subject: Avoid '*' imports. --- .../messagebus/MessageBusVisitorSession.java | 33 ++++++++++++++++++---- 1 file 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; } -- cgit v1.2.3