diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-23 09:53:50 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-23 09:53:50 +0200 |
commit | 4c39893e8d5d3ecf13b22f9da3d33c875aef4a6a (patch) | |
tree | ec4913b727a817efb62e573c313aa23bc91be3fd /vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java | |
parent | 4c4afce3ab48fdfca83f0a3217d0fe18431e68a7 (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-x | vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java | 6 |
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() { |