MimeAggregator extends MessageAggregatorImpl { public void setEncoding(String s) { encoding = s; }  @Override void joinMessage(AdaptrisMessage original, Collection<AdaptrisMessage> messages); @Override void aggregate(AdaptrisMessage original, Iterable<AdaptrisMessage> msgs); String getEncoding(); void setEncoding(String s); String getMimeContentSubType(); void setMimeContentSubType(String s); String getPartContentId(); void setPartContentId(String s); String getPartContentType(); void setPartContentType(String s); MetadataFilter getPartHeaderFilter(); void setPartHeaderFilter(MetadataFilter filter); MetadataFilter getMimeHeaderFilter(); void setMimeHeaderFilter(MetadataFilter filter); T withPartHeaderFilter(MetadataFilter filter); T withMimeHeaderFilter(MetadataFilter filter); T withMimeContentSubType(String s); T withPartContentId(String s); T withPartContentType(String s); T withEncoding(String s);  }
@Test public void testService_MimeSplitter() throws Exception { AdaptrisMessage msg = MimeJunitHelper.create(); SplitJoinService service = new SplitJoinService(); service.setService(new NullService()); service.setTimeout(new TimeInterval(10L, TimeUnit.SECONDS)); service.setSplitter(new MimePartSplitter()); MimeAggregator aggr = createAggregatorForTests(); aggr.setEncoding("base64"); service.setAggregator(aggr); execute(service, msg); BodyPartIterator input = MimeHelper.createBodyPartIterator(msg); assertEquals(4, input.size()); }