MetadataDataInputParameter implements DataInputParameter<String> { @Override public String extract(InterlokMessage message) { return message.getMessageHeaders().get(this.getMetadataKey()); } MetadataDataInputParameter();  MetadataDataInputParameter(String key); @Override String extract(InterlokMessage message); String getMetadataKey(); void setMetadataKey(String key);  }
@Test public void testExtract() throws Exception { MetadataDataInputParameter p = new MetadataDataInputParameter(); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(); msg.addMessageHeader(MetadataDataInputParameter.DEFAULT_METADATA_KEY, TEXT); assertNotSame(TEXT, msg.getContent()); assertEquals(TEXT, p.extract(msg)); }