NullMessageAggregator implements MessageAggregator { @Override public void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs) throws CoreException { }  @Override void joinMessage(AdaptrisMessage msg, Collection<AdaptrisMessage> msgs);  }
@Test public void testJoinMessage() throws Exception { NullMessageAggregator aggr = createAggregatorForTests(); AdaptrisMessage original = AdaptrisMessageFactory.getDefaultInstance().newMessage("Goodbye"); original.addMetadata("originalKey", "originalValue"); AdaptrisMessage splitMsg1 = AdaptrisMessageFactory.getDefaultInstance().newMessage("Cruel"); AdaptrisMessage splitMsg2 = AdaptrisMessageFactory.getDefaultInstance().newMessage("World"); splitMsg1.addMetadata("originalKey", "newValue"); aggr.joinMessage(original, Arrays.asList(new AdaptrisMessage[] { splitMsg1, splitMsg2 })); assertEquals("Goodbye", original.getContent()); assertEquals("originalValue", original.getMetadataValue("originalKey")); }