@Test public void testHandleProduceException() throws Exception { MockChannel channel = createChannel(); PoolingWorkflow wf = (PoolingWorkflow) channel.getWorkflowList().get(0); MockMessageProducer meh = new MockMessageProducer(); MockMessageProducer prod = new MockMessageProducer() { @Override protected void doProduce(AdaptrisMessage msg, String endpoint) throws ProduceException { throw new ProduceException(); } }; wf.setProducer(prod); channel.setMessageErrorHandler(new StandardProcessingExceptionHandler( new ServiceList(new ArrayList<Service>(Arrays.asList(new Service[] { new StandaloneProducer(meh) }))))); try { start(channel); submitMessages(wf, 1); waitForMessages(meh, 1); assertEquals(1, meh.messageCount()); } finally { stop(channel); } }
@Override public synchronized void handleProduceException() { super.handleProduceException(); }
PoolingWorkflow extends WorkflowImp { @Override public synchronized void handleProduceException() { super.handleProduceException(); } }
PoolingWorkflow extends WorkflowImp { @Override public synchronized void handleProduceException() { super.handleProduceException(); } PoolingWorkflow();  PoolingWorkflow(String uniqueId); }
PoolingWorkflow extends WorkflowImp { @Override public synchronized void handleProduceException() { super.handleProduceException(); } 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 { @Override public synchronized void handleProduceException() { super.handleProduceException(); } 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; }