aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
diff options
context:
space:
mode:
authorHarald Musum <musum@oath.com>2018-10-29 19:52:13 +0100
committerGitHub <noreply@github.com>2018-10-29 19:52:13 +0100
commit27a98339d105f0ef7b3cd7397379e251115f8f60 (patch)
treedc809780a7fefd5ce92655c381852bbfc72e0880 /vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
parent3caf9568a1c69b4ce79b4df6d9fcaeb313cd80d8 (diff)
Revert "Also obey the timeout."
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java13
1 files changed, 3 insertions, 10 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 6f9d539855e..e0e12b26ae6 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
@@ -19,18 +19,16 @@ public class SingleSender implements SimpleFeedAccess {
private final SharedSender.ResultCallback owner;
private final SharedSender sender;
private final List<MessageProcessor> messageProcessors = new ArrayList<>();
- private final long timeofDoom;
private boolean blockingQueue;
- public SingleSender(SharedSender.ResultCallback owner, SharedSender sender, long timeoutMS, boolean blockingQueue) {
+ public SingleSender(SharedSender.ResultCallback owner, SharedSender sender, boolean blockingQueue) {
this.owner = owner;
this.sender = sender;
- timeofDoom = System.currentTimeMillis() + timeoutMS;
this.blockingQueue = blockingQueue;
}
- public SingleSender(SharedSender.ResultCallback owner, int timeoutMS, SharedSender sender) {
- this(owner, sender, timeoutMS, true);
+ public SingleSender(SharedSender.ResultCallback owner, SharedSender sender) {
+ this(owner, sender, true);
}
@Override
@@ -105,9 +103,4 @@ public class SingleSender implements SimpleFeedAccess {
@Override
public void close() { }
-
- @Override
- boolean hasTimedOut() {
- return System.currentTimeMillis() > timeofDoom;
- }
}