java - StreamListener内部是否调用MessageChannel.send(Message message)

Question

在我们的应用程序中，我们使用 kafka 并有一个像这样的 Spring Cloud 输入流

@Component
public interface SomeChannel {
    @Input(ChannelNames.SOME_INPUT)
    MessageChannel someInput();
}

现在，一位同事建议添加一个实现 preSend 方法的 ChannelInterceptor 实现。然而，在我们的代码库中似乎没有人调用 MessageChannel.send(Message<?> message)在此输入 channel 上，但我们确实有一个如下所示的 StreamListener

    @StreamListener(ChannelNames.SOME_INPUT)
    public void process(final String strMessage) throws Exception {

我的问题
我认为 preSend 永远不会被调用。我是否在这里遗漏了一些东西，它仍然可能被调用(可能通过 StreamListener 代码在内部或以其他方式调用 MessageChannel.send(Message<?> message) )？

Answer 1

是的；绑定(bind)器将传入消息发送到 channel 。