用于更改JMS入站通道适配器选择器的Spring集成控制总线消息

Question

我目前正在一个基于Spring集成（3.0.1.RELEASE版）的应用程序上实现一个流，该应用程序需要将消息存储在JMS队列上，以便稍后提取。为此，我一直在尝试使用带有自定义选择器的Spring Integration JMS入站通道适配器，然后通过将JMSDestinationPollingSource的JMS选择器更改为作为头属性包含的某个匹配ID，从队列中提取消息。

其中一个要求是，我无法添加新的服务或JAVA方法，因此我一直在尝试使用控制总线对其进行排序，但在发送消息以将messageSelector设置为其他内容时，仍会收到相同的错误。

入站通道适配器定义：

<int-jms:inbound-channel-adapter id="inboundAdapter"
                                 channel="inboundChannel"
                                 destinationName="bufferQueue"
                                 connection-factory="connectionFactory"
                                 selector="matchingID = 'NO VALUE'">
    <int:poller fixed-delay="1000"/>
</int-jms:inbound-channel-adapter>

信息：

@'inboundAdapter.source'.setMessageSelector("matchingID = 'VALUE'")

错误：

EvaluationException: The method 'public void org.springframework.integration.jms.JmsDestinationPollingSource.setMessageSelector(java.lang.String)' is not supported by this command processor. If usign the Control Bus, consider adding @ManagedOperation or @ManagedAttribute.

这，AFAIK，意味着JmsDestinationPollingSource类不可管理Control Bus，因为它没有传递ControlBusmetodFilter。

这种方法是不可行的，还是我遗漏了什么？有没有办法只使用SI XML配置文件动态设置选择器？

Answer 1

首先，使用Java工具很奇怪，不允许在Java上编写代码。。。

但这是你的选择，或者像你说的那样。

换雇主！；-）

正确的：控制总线只允许@ManagedAction和@Managed属性方法。因为JmsDestinationPollingSource.setMessageSelector。我们可以这样做。但是如果我们可以用不同的方法来达到它，它有那么多意义吗？

<int:outbound-channel-adapter id="changeSelectorChannel" 
    ref"inboundAdapter.source method="setMessageSelector"/>

其中，新的选择器表达式应作为此通道的消息的有效负载。