java - 如何创建一个 Spring-XD 处理器模块来过滤发送到输出 channel 的消息

Question

有很多关于如何在java中编写变压器等的示例，但没有关于过滤器的示例(除了脚本类型过滤器，但我想使用java方法)。

我想创建一个自定义 java 过滤器来过滤从源到接收器的消息负载。

过滤器的例子都引用了一个表达式。

(如何)我可以告诉上下文执行指定类中的java方法作为表达式吗？

Answer 1

那么，实现自定义处理器模块需要什么。只需遵循 Spring XD Guilde 中的自定义 Transformer 示例即可

过滤器的自定义选择器:

public class MySelector implements MessageSelector {

     boolean accept(Message<?> message) {
      ...
    }
}

模块 ctx myfilter.xml:

<channel id="input"/>

<filter input-channel="input" output-channel="output">
    <beans:bean class="custom.MySelector" />
</filter>

<channel id="output"/>

将您的类打包到 jar 中，并将所有内容放入目录 ${xd.home}/modules/processors/myfilter ，其结构为:

/myfilter
   /config
      myfilter.xml
   /lib
      myfilter.jar

像这样测试:

xd:> stream create --name filtertest --definition "http | myfilter | log"