diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-09-30 17:08:41 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-09-30 17:08:41 +0200 |
| commit | 34dd2f7153f4a6cd1ea0b802f28cde8abdd48707 (patch) | |
| tree | 6c6d950bc1bf7c0b1421a78ecaeb07f147580b2e /vespaclient-java | |
| parent | c725da6bc08a2caf0767b8ae4d63fc98c367cd67 (diff) | |
Less unusable options.
Diffstat (limited to 'vespaclient-java')
| -rwxr-xr-x | vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java b/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java index b1fd8e8cffa..a32aa75d994 100755 --- a/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java +++ b/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java @@ -2,7 +2,6 @@ package com.yahoo.dummyreceiver; import com.yahoo.concurrent.DaemonThreadFactory; -import com.yahoo.documentapi.ThroughputLimitQueue; import com.yahoo.documentapi.messagebus.MessageBusDocumentAccess; import com.yahoo.documentapi.messagebus.MessageBusParams; import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet; @@ -42,7 +41,6 @@ public class DummyReceiver implements MessageHandler { private boolean instant = false; private ThreadPoolExecutor executor = null; private int threads = 10; - private long maxQueueTime = -1; private BlockingQueue<Runnable> queue; private boolean verbose = false; private boolean helpOption = false; @@ -76,7 +74,7 @@ public class DummyReceiver implements MessageHandler { params.getMessageBusParams().setMaxPendingCount(0); params.getMessageBusParams().setMaxPendingSize(0); da = new MessageBusDocumentAccess(params); - queue = (maxQueueTime < 0) ? new LinkedBlockingDeque<>() : new ThroughputLimitQueue<>(maxQueueTime); + queue = new LinkedBlockingDeque<>(); session = da.getMessageBus().createDestinationSession("default", true, this); executor = new ThreadPoolExecutor(threads, threads, 5, TimeUnit.SECONDS, queue, new DaemonThreadFactory()); System.out.println("Registered listener at " + name + "/default with 0 max pending and sleep time of " + sleepTime); @@ -156,8 +154,6 @@ public class DummyReceiver implements MessageHandler { instant = true; } else if ("--silent".equals(arg)) { silentNum = Long.parseLong(getParam(args, arg)); - } else if ("--maxqueuetime".equals(arg)) { - maxQueueTime = Long.parseLong(getParam(args, arg)); } else if ("--threads".equals(arg)) { threads = Integer.parseInt(getParam(args, arg)); } else if ("--verbose".equals(arg)) { |