我正在使用
camel-quarkus-activemq:3.7.0
lib 和 ActiveMQ:5.13.0
客户端。我在没有选择器的情况下消费没有任何问题,但使用选择器它就不会消费。没有错误。我使用了这里的示例:https://camel.apache.org/components/4.0.x/eips/selective-consumer.html#_selective_consumer_using_components
我尝试使用Camel的选择性消费者,例如:
from("jms:queue:TESTQUEU?selector=Type='MEL'") .log("Received message body: ${body}") .to("direct:done");
我希望它消费来自
TESTQUEU
的消息,但我的消费者不消费并且没有给出错误。 ActiveMQ 将其显示为活跃消费者,并且有带有 Type='MEL'
和 Type=MEL
的消息,以防万一。
没有选择器
from("jms:queue:TESTQUEU")...
消息已成功消费。
附注抱歉,我的队列名称输入错误。
请尝试在选择性消费者中使用 SELECTIVE CONSUMER USING FILTER EIP 方法,因为您似乎想使用消息头属性。