Остановить продолжение потока в devkit @processor

Question

Существует ли согласованный способ остановить продолжение потока в рамках метода devit @процессора? Я хочу, чтобы он вел себя как фильтр, где сообщение отбрасывается.

Answer 1

Да: определить его как перехватчик.

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