ValidatorModule.java

@Module(name = "validator", schemaVersion = "1.0-SNAPSHOT")
public class ValidatorModule {


    /**
     * Processor to filter our invalid products from a List payload.
     * <p/>
     * {@sample.xml ../../../doc/Validator-connector.xml.sample validator:my-processor}
     *
     * @param products The products to validate
     * @return The products which are valid
     */
    @Processor(name = "product")
    public Object validateProducts(@Payload List<Map> products) throws Exception {

        List<Map> validProducts = new ArrayList<Map>();

        for (Map product : products) {
            if (product.containsKey("sku") || product.containsKey("product_id")) {
                validProducts.add(product);
            }
        }

        return validProducts;
    }


}