aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-23 09:53:50 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-23 09:53:50 +0200
commit4c39893e8d5d3ecf13b22f9da3d33c875aef4a6a (patch)
treeec4913b727a817efb62e573c313aa23bc91be3fd /vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
parent4c4afce3ab48fdfca83f0a3217d0fe18431e68a7 (diff)
Remove dependency to unmaintained metrics library and stuff only used for /feed api.
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java6
1 files changed, 2 insertions, 4 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
index 9d0c740789e..d78e3a62302 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
@@ -19,12 +19,10 @@ public class SingleSender implements SimpleFeedAccess {
private final SharedSender.ResultCallback owner;
private final SharedSender sender;
private final List<MessageProcessor> messageProcessors = new ArrayList<>();
- private boolean blockingQueue;
- public SingleSender(SharedSender.ResultCallback owner, SharedSender sender, boolean blockingQueue) {
+ public SingleSender(SharedSender.ResultCallback owner, SharedSender sender) {
this.owner = owner;
this.sender = sender;
- this.blockingQueue = blockingQueue;
}
@Override
@@ -86,7 +84,7 @@ public class SingleSender implements SimpleFeedAccess {
* @param m The message to send
*/
public void send(Message m) {
- sender.send(processMessage(m), owner, blockingQueue);
+ sender.send(processMessage(m), owner, true);
}
public void done() {