CEPExample.java

Pattern<Shipment, ?> pattern = Pattern.<Shipment>begin("start").where(new SimpleCondition<Shipment>() {
    @Override
    public boolean filter(Shipment value) throws Exception {
      // Check where the shipment came from
      return value.from.equals("A");
    }
}).followedByAny("middle").where(new IterativeCondition<Shipment>() {
    @Override
    public boolean filter(Shipment value, Context<Shipment> ctx) throws Exception {
        Iterator<Shipment> it = ctx.getEventsForPattern("middle").iterator();
        // Iterate through stops along the shipment route
        if (!it.hasNext()) {
            return ctx.getEventsForPattern("start").iterator().next().to.equals(value.from);
        }

        String to = null;
        while (it.hasNext()) {
            to = it.next().to;
        }
        return value.from.equals(to);
    }
}).oneOrMore().followedByAny("end").where(new IterativeCondition<Shipment>() {
    @Override
    public boolean filter(Shipment value, Context<Shipment> ctx) throws Exception {
        int counter = 0;
        String to = null;

        Iterator<Shipment> it = ctx.getEventsForPattern("middle").iterator();
        while (it.hasNext()) {
            to = it.next().to;
            counter++;
        }
        // Check if the shipment had at least 5 stops and that the from and to values are what we expect
        return counter >= 5 && to.equals(value.from) && value.to.equals("B");
    }
}).within(Time.hours(24));