RuntimeException failure2 = new RuntimeException('broken2')

        when:
        dispatch.dispatchFailed("message1", failure1)
        dispatch.dispatchFailed("message2", failure2)
        dispatch.stop()

        then:
        def e = thrown(DispatchException)
        e.cause == failure1
        1 * logger.error('broken2', failure2)
        0 * logger._
    }

        def failure = new RuntimeException()

        when:
        dispatch.dispatch("message")

        then:
        1 * target.dispatch("message") >> { throw failure }
        1 * handler.dispatchFailed("message", failure)
    }

    def "propagates exception thrown by handler"() {
        def failure = new RuntimeException()
        def adaptedFailure = new RuntimeException()

        when:

public interface DispatchFailureHandler<T> {
    /**
     * Called when a message could not be dispatched. This method can throw an exception to abort further dispatching.
     */
    void dispatchFailed(T message, Throwable failure);

        this.handler = handler;
    }

    @Override
    public void dispatch(T message) {
        try {
            dispatch.dispatch(message);
        } catch (Throwable throwable) {
            handler.dispatchFailed(message, throwable);
        }
    }

    private final Logger logger;
    private DispatchException failure;

    public ExceptionTrackingFailureHandler(Logger logger) {
        this.logger = logger;
    }

    @Override
    public void dispatchFailed(Object message, Throwable failure) {
        if (this.failure != null && !Thread.currentThread().isInterrupted()) {
            logger.error(failure.getMessage(), failure);
        } else {