Mule JMS主题和ActiveMQ配置

Question

我使用Mule ESB来设计一个过程，通过这个过程可以向一个主题发布消息。订阅者将收听主题并接收消息。每个用户对消息的反应不同。这里的目标是能够从HTTP向主题发送测试消息，以测试订阅者。

下面是如何配置JMS连接：

 <!-- JMS Topic connector -->
<jms:activemq-connector name="jmsTopicConnection" specification="1.1" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ2" durable="true" numberOfConcurrentTransactedReceivers="2"/>

这是流程：

<flow name="auditJMSServiceFlow">
<http:listener config-ref="HTTP" path="/Audit/Activity" responseStreamingMode="ALWAYS" doc:name="HTTP"/>
<set-variable variableName="#['id']" value="#[message.inboundProperties['id']]" doc:name="set dynamic id"/>
<set-payload value="===TOPIC===" doc:name="Set Payload" />

 <request-reply storePrefix="mainFlow">
<jms:inbound-endpoint topic="Audit.Activity" connector-ref="jmsTopicConnection" doc:name="JMS Topic Audit.Activity" exchange-pattern="request-response" durableName="audit_activity">
    <jms:transaction action="ALWAYS_BEGIN" />
    <!-- Not required to explicitly have this element.  Mule will put this in implicitly. -->
    <!-- <jms:jmsmessage-to-object-transformer displayName="JmsMsg to Object"/> -->
</jms:inbound-endpoint>
</request-reply>

<json:object-to-json-transformer doc:name="transform JMS message to JSON"/>
<json:validate-schema schemaLocation="resource://AuditMsgSchema.json" doc:name="Validate Json Schema"/>
<component class="com.baml.panther.audit.service.impl.AuditServiceImpl" doc:name="Java"/>


<default-exception-strategy>
    <commit-transaction exception-pattern="com.foo.ExpectedExceptionType"/> 
    <jms:outbound-endpoint queue="dead.letter" connector-ref="jmsConnection"> 
        <jms:transaction action="JOIN_IF_POSSIBLE" />
    </jms:outbound-endpoint>
</default-exception-strategy>

<logger message="=== #[message.payload] received #[org.mule.util.DateUtiles.getTimeStamp('dd-MM-yyyy_HH-mm-ss.SSS')]" level="INFO" doc:name="Logger"/>

当我运行测试时，我得到以下错误：

任何建议将不胜感激。

罗斯

Answer 1

问题是您不能将消息源作为请求-回复中的第一个消息处理器。请求回复允许您对JMS之类的异步协议进行同步调用。如果您想在放置请求-回复的地方向消息代理发送消息，只需放置一个JMS出站endpoint。如果您想要使用来自JMS主题的消息，您必须将JMS入站endpoint作为流中的第一个消息处理器。

Answer 2

对于错误：您的estest-回复范围缺少出站endpoint。您只有入站endpoint（jms： ininding-endpoint）。您还需要提供出站endpoint。

<request-reply storePrefix="mainFlow">
<jms:inbound-endpoint topic="Audit.Activity" connector-ref="jmsTopicConnection" doc:name="JMS Topic Audit.Activity" exchange-pattern="request-response" durableName="audit_activity">
    <jms:transaction action="ALWAYS_BEGIN" />
    <!-- Not required to explicitly have this element.  Mule will put this in implicitly. -->
    <!-- <jms:jmsmessage-to-object-transformer displayName="JmsMsg to Object"/> -->
</jms:inbound-endpoint>
</request-reply>

不确定你的目标是什么，但如果你只放一个jms：出站入口（而不是整个请求-回复块），你可以向JMS主题发送一条消息。