我能够根据 mule 文档使用mule-ha-bundle-2.0设置集群,但在同一网络中连接的两台不同机器中的两个节点,并且可以部署具有如下所示的 vm 和 logger 的流。
<flow name="vmc-flow" doc:name="vmc-jc-flow">
<vm:inbound-endpoint exchange-pattern="one-way"
path="vmq1" doc:name="vmq1-listner" />
<logger
message="Request hit to server: #[server.host] at time: #[server.dateTime] from the flow: #[flow.name] with payload: #[payload] and message id : #[message.id.toString()]"
level="INFO" doc:name="log-info" />
</flow>
现在我的问题是:如何将消息推送到那个特定的 vm-queue?
我有一个使用过的另一个(下面)mule 应用程序,它再次部署在同一个集群上,但监听器'vmq1'没有使用这些应用程序
<spring:beans>
<context:property-placeholder location="test-cluster-app.properties" />
</spring:beans>
<flow name="test-vmc-invoke" doc:name="test-vmc-invoke">
<http:inbound-endpoint exchange-pattern="request-response"
host="${http.host}" port="${http.port}" doc:name="HTTP" path="${http.path}" />
<expression-filter expression="#[payload !='favicon.ico']"
doc:name="filter-favicon" />
<set-payload value="#[string:from http]" doc:name="set-payload" />
<logger
message="sending message to vmq1 at time #[server.dateTime], flow #[flow.name]"
level="INFO" doc:name="log-info" />
<vm:outbound-endpoint exchange-pattern="one-way"
path="vmq1" doc:name="vmq1-dispatcher">
</vm:outbound-endpoint>
</flow>
注意:我能够点击 http 并将消息推送到“vmq1”
请帮助我了解我哪里出错了。