@Test public void testSetShutdownWaitTime() throws Exception { PoolingWorkflow workflow = new PoolingWorkflow(); TimeInterval defaultInterval = new TimeInterval(60L, TimeUnit.SECONDS.name()); assertNull(workflow.getShutdownWaitTime()); assertEquals(defaultInterval.toMilliseconds(), workflow.shutdownWaitTimeMs()); TimeInterval interval = new TimeInterval(200L, TimeUnit.MILLISECONDS.name()); workflow.setShutdownWaitTime(interval); assertEquals(interval, workflow.getShutdownWaitTime()); assertNotSame(defaultInterval.toMilliseconds(), workflow.shutdownWaitTimeMs()); assertEquals(interval.toMilliseconds(), workflow.shutdownWaitTimeMs()); workflow.setShutdownWaitTime(null); assertNull(workflow.getShutdownWaitTime()); assertEquals(defaultInterval.toMilliseconds(), workflow.shutdownWaitTimeMs()); }
public void setShutdownWaitTime(TimeInterval interval) { shutdownWaitTime = interval; }
PoolingWorkflow extends WorkflowImp { public void setShutdownWaitTime(TimeInterval interval) { shutdownWaitTime = interval; } }
PoolingWorkflow extends WorkflowImp { public void setShutdownWaitTime(TimeInterval interval) { shutdownWaitTime = interval; } PoolingWorkflow();  PoolingWorkflow(String uniqueId); }
PoolingWorkflow extends WorkflowImp { public void setShutdownWaitTime(TimeInterval interval) { shutdownWaitTime = interval; } PoolingWorkflow();  PoolingWorkflow(String uniqueId); void setPoolSize(Integer i); Integer getPoolSize(); int poolSize(); long threadLifetimeMs(); long shutdownWaitTimeMs(); TimeInterval getThreadKeepAlive(); void setThreadKeepAlive(TimeInterval interval); TimeInterval getShutdownWaitTime(); void setShutdownWaitTime(TimeInterval interval); @Override void onAdaptrisMessage(final AdaptrisMessage msg, Consumer<AdaptrisMessage> success, Consumer<AdaptrisMessage> failure); @Override synchronized void handleBadMessage(AdaptrisMessage msg); @Override synchronized void doProduce(AdaptrisMessage msg); @Override synchronized void handleProduceException(); Integer getThreadPriority(); void setThreadPriority(Integer i); Integer getMinIdle(); void setMinIdle(Integer i); int minIdle(); Integer getMaxIdle(); void setMaxIdle(Integer i); int maxIdle(); int threadPriority(); TimeInterval getInitWaitTime(); void setInitWaitTime(TimeInterval t); long initWaitTimeMs(); int currentObjectPoolCount(); int currentlyActiveObjects(); int currentlyIdleObjects(); int currentThreadPoolCount(); }
PoolingWorkflow extends WorkflowImp { public void setShutdownWaitTime(TimeInterval interval) { shutdownWaitTime = interval; } PoolingWorkflow();  PoolingWorkflow(String uniqueId); void setPoolSize(Integer i); Integer getPoolSize(); int poolSize(); long threadLifetimeMs(); long shutdownWaitTimeMs(); TimeInterval getThreadKeepAlive(); void setThreadKeepAlive(TimeInterval interval); TimeInterval getShutdownWaitTime(); void setShutdownWaitTime(TimeInterval interval); @Override void onAdaptrisMessage(final AdaptrisMessage msg, Consumer<AdaptrisMessage> success, Consumer<AdaptrisMessage> failure); @Override synchronized void handleBadMessage(AdaptrisMessage msg); @Override synchronized void doProduce(AdaptrisMessage msg); @Override synchronized void handleProduceException(); Integer getThreadPriority(); void setThreadPriority(Integer i); Integer getMinIdle(); void setMinIdle(Integer i); int minIdle(); Integer getMaxIdle(); void setMaxIdle(Integer i); int maxIdle(); int threadPriority(); TimeInterval getInitWaitTime(); void setInitWaitTime(TimeInterval t); long initWaitTimeMs(); int currentObjectPoolCount(); int currentlyActiveObjects(); int currentlyIdleObjects(); int currentThreadPoolCount(); static final int DEFAULT_MAX_POOLSIZE; static final int DEFAULT_MIN_IDLE; static final int DEFAULT_MAX_IDLE; }