@Test(expected = CoreException.class) public void testAggregate_BrokenOutput() throws Exception { ZipAggregator aggr = new ZipAggregator(); AdaptrisMessage original = new DefectiveMessageFactory(WhenToBreak.OUTPUT).newMessage(); AdaptrisMessageFactory fac = AdaptrisMessageFactory.getDefaultInstance(); AdaptrisMessage splitMsg1 = fac.newMessage("<document>hello</document>"); splitMsg1.addMetadata(DEFAULT_FILENAME_METADATA, "xfile1.xml"); AdaptrisMessage splitMsg2 = fac.newMessage("<document>world2</document>"); splitMsg2.addMetadata(DEFAULT_FILENAME_METADATA, "file2.xml"); AdaptrisMessage splitMsg3 = fac.newMessage("<document>world3</document>"); splitMsg3.addMetadata(DEFAULT_FILENAME_METADATA, "xfile3.xml"); AdaptrisMessage splitMsg4 = fac.newMessage("<document>world4</document>"); splitMsg4.addMetadata(DEFAULT_FILENAME_METADATA, "file4.xml"); AdaptrisMessage willBeIgnoredMsg = fac.newMessage("<document>world4</document>"); aggr.joinMessage(original, Arrays.asList(splitMsg1, splitMsg2, splitMsg3, splitMsg4, willBeIgnoredMsg)); }
@Override public void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs) throws CoreException { aggregate(msg, msgs); }
ZipAggregator extends MessageAggregatorImpl { @Override public void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs) throws CoreException { aggregate(msg, msgs); } }
ZipAggregator extends MessageAggregatorImpl { @Override public void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs) throws CoreException { aggregate(msg, msgs); }  }
ZipAggregator extends MessageAggregatorImpl { @Override public void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs) throws CoreException { aggregate(msg, msgs); }  @Override void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs); @Override void aggregate(AdaptrisMessage original, Iterable<AdaptrisMessage> messages); }
ZipAggregator extends MessageAggregatorImpl { @Override public void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs) throws CoreException { aggregate(msg, msgs); }  @Override void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs); @Override void aggregate(AdaptrisMessage original, Iterable<AdaptrisMessage> messages); static final String DEFAULT_FILENAME_METADATA; }