{
final UnmarshalProcessor unmarshalProcessor = new UnmarshalProcessor(dataFormatter);
final DefaultExchange exchange = new DefaultExchange(camelContext);
exchange.getIn().setBody(getCustomerInputStream(CUSTOMER_XML));
unmarshalProcessor.process(exchange);
assertEquals(Customer.class, exchange.getOut().getBody().getClass());
}
@Test