@Test public void testService_MultipleMessages() throws Exception { GuidGenerator o = new GuidGenerator(); File tempDir = TempFileUtils.createTrackedDir(o); String url = "file: ConsumeDestinationGenerator cdg = createConsumeDestination(url, ".*"); AggregatingFsConsumer afc = createConsumer(cdg, new IgnoreOriginalMimeAggregator()); AggregatingFsConsumeService service = createAggregatingService(afc); try { writeDataMessage(tempDir, o.safeUUID()); writeDataMessage(tempDir, o.safeUUID()); start(service); AdaptrisMessage msg = new DefaultMessageFactory().newMessage(INITIAL_PAYLOAD); service.doService(msg); BodyPartIterator input = MimeHelper.createBodyPartIterator(msg); assertEquals(2, input.size()); } finally { stop(service); } }
@Override public void doService(AdaptrisMessage msg) throws ServiceException { try { start(fsConsumer); fsConsumer.aggregateMessages(msg, this); } finally { stop(fsConsumer); } }
AggregatingFsConsumeService extends AggregatingConsumeServiceImpl<NullConnection> { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { start(fsConsumer); fsConsumer.aggregateMessages(msg, this); } finally { stop(fsConsumer); } } }
AggregatingFsConsumeService extends AggregatingConsumeServiceImpl<NullConnection> { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { start(fsConsumer); fsConsumer.aggregateMessages(msg, this); } finally { stop(fsConsumer); } } AggregatingFsConsumeService(); }
AggregatingFsConsumeService extends AggregatingConsumeServiceImpl<NullConnection> { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { start(fsConsumer); fsConsumer.aggregateMessages(msg, this); } finally { stop(fsConsumer); } } AggregatingFsConsumeService(); @Override void doService(AdaptrisMessage msg); AggregatingFsConsumer getFsConsumer(); void setFsConsumer(AggregatingFsConsumer fsConsumer); @Override void prepare(); }
AggregatingFsConsumeService extends AggregatingConsumeServiceImpl<NullConnection> { @Override public void doService(AdaptrisMessage msg) throws ServiceException { try { start(fsConsumer); fsConsumer.aggregateMessages(msg, this); } finally { stop(fsConsumer); } } AggregatingFsConsumeService(); @Override void doService(AdaptrisMessage msg); AggregatingFsConsumer getFsConsumer(); void setFsConsumer(AggregatingFsConsumer fsConsumer); @Override void prepare();  }