Search code examples
muledevkit

Stop the continuation of a flow within a devkit @processor


Is there an agreed upon way to stop the continuation of a flow within a devit @processor method? I want it to behave like a filter, where the message is dropped.


Solution

  • Yes: define it as an intercepting processor.

    @Processor(intercepting = true)
    public Something foo(..., final SourceCallback sourceCallback)