@Test public void testSetPoolSize() throws Exception { PoolingWorkflow workflow = new PoolingWorkflow(); workflow.setPoolSize(20); assertEquals(20, workflow.poolSize()); assertEquals(20, workflow.getPoolSize().intValue()); workflow.setPoolSize(null); assertNull(workflow.getPoolSize()); assertEquals(DEFAULT_MAX_POOLSIZE, workflow.poolSize()); }
public void setPoolSize(Integer i) { poolSize = i; }
PoolingWorkflow extends WorkflowImp { public void setPoolSize(Integer i) { poolSize = i; } }
PoolingWorkflow extends WorkflowImp { public void setPoolSize(Integer i) { poolSize = i; } PoolingWorkflow();  PoolingWorkflow(String uniqueId); }
PoolingWorkflow extends WorkflowImp { public void setPoolSize(Integer i) { poolSize = i; } 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 setPoolSize(Integer i) { poolSize = i; } 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; }