是否有一种商定的方法来停止devit@processor方法中流的继续？我希望它表现得像一个过滤器，在那里丢弃消息。
是：将其定义为拦截处理器。
@Processor(intercepting = true)
public Something foo(..., final SourceCallback sourceCallback)