@Test public void testService_Events() throws Exception { PooledSplitJoinService service = new PooledSplitJoinService(); MockMessageProducer events = new MockMessageProducer(); service.setAggregator(new AppendingMessageAggregator()); service.setSplitter(new LineCountSplitter(1)); service.setPoolsize(10); service.setTimeout(new TimeInterval(10L, TimeUnit.SECONDS)); service.setService(new WaitService(new TimeInterval(100L, TimeUnit.MILLISECONDS), true)); service.setSendEvents(true); service.registerEventHandler(LifecycleHelper.initAndStart(new DefaultEventHandler(events))); AdaptrisMessage msg = createLineCountMessageInput(50); ExampleServiceCase.execute(service, msg); List<String> result = IOUtils.readLines(msg.getReader()); assertEquals(50 * 2, result.size()); assertEquals(50, events.getMessages().size()); }
@Override public void registerEventHandler(EventHandler eh) { eventHandler = eh; }
PooledSplitJoinService extends ServiceImp implements EventHandlerAware, ServiceWrapper { @Override public void registerEventHandler(EventHandler eh) { eventHandler = eh; } }
PooledSplitJoinService extends ServiceImp implements EventHandlerAware, ServiceWrapper { @Override public void registerEventHandler(EventHandler eh) { eventHandler = eh; }  }
PooledSplitJoinService extends ServiceImp implements EventHandlerAware, ServiceWrapper { @Override public void registerEventHandler(EventHandler eh) { eventHandler = eh; }  @Override void prepare(); @Override void start(); @Override void stop(); @Override void doService(AdaptrisMessage msg); @Override void registerEventHandler(EventHandler eh); @Override Service[] wrappedServices(); }
PooledSplitJoinService extends ServiceImp implements EventHandlerAware, ServiceWrapper { @Override public void registerEventHandler(EventHandler eh) { eventHandler = eh; }  @Override void prepare(); @Override void start(); @Override void stop(); @Override void doService(AdaptrisMessage msg); @Override void registerEventHandler(EventHandler eh); @Override Service[] wrappedServices();  }