gistfile1.java

/**
     * Custom processor
     * <p/>
     * {@sample.xml ../../../doc/CircuitBreaker-connector.xml.sample circuitbreaker:filter}
     *
     * @param payload The message payload
     * @return Some string
     */
    @Processor
    public Object filter(@Payload Object payload) {
        if (getFailureCount() < tripThreshold) {
            return payload;
        } else if (breakerTrippedOn != null && System.currentTimeMillis() - breakerTrippedOn.getTime() > tripTimeout) {
            breakerTrippedOn = null;
            resetFailureCount();
            return payload;
        } else {
            throw new CircuitOpenException();
        }
    }