class ForwardingDisabledProcessorContext implements ProcessorContext {

    @Override
    public <K, V> void forward(final K key, final V value) {
        throw new StreamsException(EXPLANATION);
    }

    public  ForwardingDisabledProcessorContext(final ProcessorContext delegate);

}