Spring IBM mq 的 correlationId 的 jms 分隔符
Spring jms separator by correlationId for IBM mq
我能够使用 JmsPutGet 和以下浏览选择器浏览我的 IBM mq 消息。
context.createBrowser(context.createQueue("queue:///" + QUEUE_NAME), "JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'")
我正在尝试使用 JmsListener 注释spring jms 来做同样的事情
更新: 将选择器更改为 JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'" 使其工作。我前一天尝试过,认为没有用。
@JmsListener(
destination = "DevQueue01",
containerFactory = "myContainerFactory",
selector = "JMSCorrelationID='c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'"
)
public void processInspection(@Valid Inspection bean) {
System.out.println("In process inspections : \n\n" + bean);
}
将选择器更改为以下使其工作。我前一天试过,认为没有用。
JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'"
我能够使用 JmsPutGet 和以下浏览选择器浏览我的 IBM mq 消息。
context.createBrowser(context.createQueue("queue:///" + QUEUE_NAME), "JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'")
我正在尝试使用 JmsListener 注释spring jms 来做同样的事情
更新: 将选择器更改为 JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'" 使其工作。我前一天尝试过,认为没有用。
@JmsListener(
destination = "DevQueue01",
containerFactory = "myContainerFactory",
selector = "JMSCorrelationID='c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'"
)
public void processInspection(@Valid Inspection bean) {
System.out.println("In process inspections : \n\n" + bean);
}
将选择器更改为以下使其工作。我前一天试过,认为没有用。
JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'"