diff options
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 | 13 |
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; - } } |