gistfile1.java

 /**
     * Custom processor
     * <p/>
     * {@sample.xml ../../../doc/CircuitBreaker-connector.xml.sample circuitbreaker:trip}
     *
     * @param exceptionMessage The exception.
     * @param tripOnException  The exception type we should trip on.
     * @return Some string
     */
    @Processor
    public Object trip(String tripOnException, @Payload ExceptionMessage exceptionMessage) {

        if (exceptionMessage.getException().getCause().getClass().getCanonicalName().equals(tripOnException)) {
            incrementFailureCount();
            if (getFailureCount() == tripThreshold) {
                breakerTrippedOn = new Date();
            }
        }
        return exceptionMessage;
    }