@Test public void testServiceWithFailures() throws Exception { PoolingMessageSplitterService service = SplitterCase.createPooling(new XpathMessageSplitter("/envelope/document", "UTF-8"), new AlwaysFailService()).withWaitWhileBusy(true); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(XML_MESSAGE); XpathMessageSplitter splitter = new XpathMessageSplitter("/envelope/document", "UTF-8"); try { execute(service, msg); fail(); } catch (ServiceException expected) { } }
public PoolingMessageSplitterService withWaitWhileBusy(Boolean b) { setWaitWhileBusy(b); return this; }
PoolingMessageSplitterService extends AdvancedMessageSplitterService { public PoolingMessageSplitterService withWaitWhileBusy(Boolean b) { setWaitWhileBusy(b); return this; } }
PoolingMessageSplitterService extends AdvancedMessageSplitterService { public PoolingMessageSplitterService withWaitWhileBusy(Boolean b) { setWaitWhileBusy(b); return this; }  }
PoolingMessageSplitterService extends AdvancedMessageSplitterService { public PoolingMessageSplitterService withWaitWhileBusy(Boolean b) { setWaitWhileBusy(b); return this; }  @Override void start(); PoolingMessageSplitterService withWarmStart(Boolean b); PoolingMessageSplitterService withMaxThreads(Integer i); PoolingMessageSplitterService withWaitWhileBusy(Boolean b); }
PoolingMessageSplitterService extends AdvancedMessageSplitterService { public PoolingMessageSplitterService withWaitWhileBusy(Boolean b) { setWaitWhileBusy(b); return this; }  @Override void start(); PoolingMessageSplitterService withWarmStart(Boolean b); PoolingMessageSplitterService withMaxThreads(Integer i); PoolingMessageSplitterService withWaitWhileBusy(Boolean b);  }