aboutsummaryrefslogtreecommitdiffstats
path: root/jdisc_messagebus_service
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2018-10-25 10:01:25 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2018-10-25 10:01:25 +0200
commitf8ce40a8a552ba4bde8b58e6cce637890c610903 (patch)
tree5ad01eebe21d782623ce06edd7b53a14190e27a1 /jdisc_messagebus_service
parentb9ea7cfea3bde56596ca58677bcfd6412cd4ddf3 (diff)
GC unused imports.
Diffstat (limited to 'jdisc_messagebus_service')
-rw-r--r--jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java12
1 files changed, 9 insertions, 3 deletions
diff --git a/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java b/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
index 6208bc97077..f543e1b5c8d 100644
--- a/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
+++ b/jdisc_messagebus_service/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
@@ -4,8 +4,16 @@ package com.yahoo.messagebus.shared;
import com.yahoo.jdisc.AbstractResource;
import com.yahoo.jdisc.ResourceReference;
import com.yahoo.log.LogLevel;
-import com.yahoo.messagebus.*;
+import com.yahoo.messagebus.EmptyReply;
import com.yahoo.messagebus.Error;
+import com.yahoo.messagebus.ErrorCode;
+import com.yahoo.messagebus.IntermediateSession;
+import com.yahoo.messagebus.IntermediateSessionParams;
+import com.yahoo.messagebus.Message;
+import com.yahoo.messagebus.MessageHandler;
+import com.yahoo.messagebus.Reply;
+import com.yahoo.messagebus.ReplyHandler;
+import com.yahoo.messagebus.Result;
import java.util.concurrent.atomic.AtomicReference;
import java.util.logging.Logger;
@@ -19,7 +27,6 @@ public class SharedIntermediateSession extends AbstractResource
private static final Logger log = Logger.getLogger(SharedIntermediateSession.class.getName());
private final AtomicReference<MessageHandler> msgHandler = new AtomicReference<>();
- private final SharedMessageBus mbus;
private final IntermediateSession session;
private final ResourceReference mbusReference;
@@ -27,7 +34,6 @@ public class SharedIntermediateSession extends AbstractResource
if (params.getReplyHandler() != null) {
throw new IllegalArgumentException("Reply handler must be null.");
}
- this.mbus = mbus;
this.msgHandler.set(params.getMessageHandler());
this.session = mbus.messageBus().createIntermediateSession(params.setReplyHandler(this)
.setMessageHandler(this));