MuleEvent response = flow.process(getTestEvent(testObjects));
List<CatalogProductEntity> products = (List<CatalogProductEntity>) response.getMessage().getPayload();
assertEquals("There should be 1 product", 1, products.size());
CatalogProductEntity product = products.get(0);
assertEquals("Product sku should be " + testObjects.get("sku"), testObjects.get("sku"), product.getSku());
}
catch (Exception e) {
e.printStackTrace();
fail();
}