@Test
public void testCanAggregateLineItems() throws Exception {
String orderId = UUID.getUUID();
for (int i=0; i<3; i++) {
LineItem lineItem = new LineItem();
Map properties = new HashMap();
properties.put("MULE_CORRELATION_ID",orderId);
properties.put("MULE_CORRELATION_GROUP_SIZE",3);
MuleMessage message = new DefaultMuleMessage(lineItem,properties,muleContext);
muleContext.getClient().dispatch("jms://lineitem.complete",message);