diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-15 13:33:56 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-15 13:33:56 +0200 |
commit | 8e62cd1238a7c98009d8695eac4c85a8da1549b5 (patch) | |
tree | a60ddc5c93bac2ece9cd5d1e9c2b07592c2a24d7 /messagebus | |
parent | 85962336458e1a33aa5f0f0130dc018d4bee7d72 (diff) |
Add control for number of feed threads.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/RPCMessageBus.java | 5 | ||||
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java | 2 |
2 files changed, 1 insertions, 6 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/RPCMessageBus.java b/messagebus/src/main/java/com/yahoo/messagebus/RPCMessageBus.java index 4bbe88ffc2c..5ea278c410b 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/RPCMessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/RPCMessageBus.java @@ -1,16 +1,12 @@ // Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.messagebus; -import com.yahoo.log.LogLevel; import com.yahoo.messagebus.network.Identity; -import com.yahoo.messagebus.network.Network; import com.yahoo.messagebus.network.rpc.RPCNetwork; import com.yahoo.messagebus.network.rpc.RPCNetworkParams; import java.util.Arrays; import java.util.List; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.logging.Logger; /** * The RPCMessageBus class wraps a MessageBus with an RPCNetwork and handles reconfiguration. Please note that according @@ -20,7 +16,6 @@ import java.util.logging.Logger; */ public class RPCMessageBus extends NetworkMessageBus { - private static final Logger log = Logger.getLogger(RPCMessageBus.class.getName()); private final ConfigAgent configAgent; /** diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java index 35218364c8f..6d1ec7586b3 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java @@ -69,7 +69,7 @@ public class Sequencer implements MessageHandler, ReplyHandler { if (seqMap.containsKey(seqId)) { Queue<Message> queue = seqMap.get(seqId); if (queue == null) { - queue = new LinkedList<Message>(); + queue = new LinkedList<>(); seqMap.put(seqId, queue); } if (msg.getTrace().shouldTrace(TraceLevel.COMPONENT)) { |