Mule请求者模块与JMS连接器

Question

我正在使用以下配置：

<dependency>
<groupId>org.mule.modules</groupId>
<artifactId>mule-module-requester</artifactId>
<version>1.6</version>

<spring:bean id="MQGatewayConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory" name="MQGatewayConnectionFactory" scope="singleton">
<spring:property name="transportType" value="1"></spring:property>
<spring:property name="connectionNameList" value="${mqm.gw.connectionNameList}"></spring:property>
<spring:property name="channel" value="${mqm.gw.channel}"></spring:property>
<spring:property name="queueManager" value="${mqm.gw.name}"></spring:property>
</spring:bean>

<jms:connector
name="WebsphereMQConnector_GW"
doc:name="WebsphereMQConnector_GW"
connectionFactory-ref="MQGatewayConnectionFactory"
username="${mqm.user}"
numberOfConsumers="4"
validateConnections="true"
maxRedelivery="-1"
cacheJmsSessions="false"
disableTemporaryReplyToDestinations="true"
persistentDelivery="true"
specification="1.1">
<reconnect-forever frequency="10000"></reconnect-forever> 
</jms:connector>


<mulerequester:request resource="jms://QUEUE.NAME?connector=WebsphereMQConnector_GW" timeout="10000" doc:name="Mule Requester"/>

这会导致以下错误：

Endpoint              : UnregistrableEndpoint{endpointUri=jms://EIS_P2_CALL_CONTEXT?connector=WebsphereMQConnector_GW, connector=JmsConnector
                    {
                      name=WebsphereMQConnector_GW
                      lifecycle=start
                      this=299786b1
                      numberOfConcurrentTransactedReceivers=4
                      createMultipleTransactedReceivers=true
                      connected=true
                      supportedProtocols=[jms]
                      serviceOverrides=<none>
                    }
                    ,  name='endpoint.jms.QUEUE.NAME', mep=ONE_WAY, properties= 
{connector=WebsphereMQConnector_GW}, transactionConfig=Transaction{factory=null, action=INDIFFERENT, 
 timeout=0}, deleteUnacceptedMessages=false, initialState=started, responseTimeout=10000, 
 endpointEncoding=UTF-8, disableTransportTransformer=false}

我还尝试按照下面提到的方式提供选择器，但仍然出错了。

&selector=JMSCorrelationID%3D'#[message.outboundProperties.MULE_CORRELATION_ID]

如果我提到连接器或不提到连接器，它都会出错。

使用连接器时的错误跟踪：

Root Exception stack trace:
org.mule.transaction.IllegalTransactionStateException: Only a single resource can be bound to this type of transaction
    at org.mule.transaction.AbstractSingleResourceTransaction.bindResource(AbstractSingleResourceTransaction.java:128)
    at org.mule.transport.jms.JmsTransaction.bindResource(JmsTransaction.java:54)
    at org.mule.transport.jms.JmsConnector.getSession(JmsConnector.java:669)
    at org.mule.transport.jms.JmsMessageRequester.doRequest(JmsMessageRequester.java:81)
    at org.mule.transport.AbstractMessageRequester.request(AbstractMessageRequester.java:94)
    at org.mule.transport.AbstractConnector.request(AbstractConnector.java:2270)
    at org.mule.endpoint.DefaultInboundEndpoint.request(DefaultInboundEndpoint.java:80)
    at org.mule.client.DefaultLocalMuleClient.requestMessage(DefaultLocalMuleClient.java:215)
    at org.mule.client.DefaultLocalMuleClient.request(DefaultLocalMuleClient.java:205)
    at org.mule.module.MuleRequesterModule.request(MuleRequesterModule.java:60)

请问为什么这样做会导致错误，即使我已经按照 Mule 文档的定义严格执行了？

- Sambit Swain

Answer 1

UnregistrableEndpoint似乎表明在创建端点时出现了问题。尝试使用相同的JMS端点正常启动流程，而不使用Mule请求器，以查看是否存在连接问题或其他问题。

您没有提供选择器问题的完整示例和错误，但在字符串中使用表达式的语法似乎不正确。

- aled

---

我尝试使用以下两种方式连接均失败：

1. resource="#['jms://QUEUE.NAME?connector=WebsphereMQConnector_GW']"
2. resource="#['jms://QUEUE.NAME?connector=WebsphereMQConnector_GW&selector=CID%3D'+message.outboundProperties.MULE_CORRELATION_ID]"

但在 jms:inbound-endpoint 中使用相同的连接器和队列就可以正常连接。 - Sambit Swain

我成功让它工作了，看起来问题只出现在我使用JMS连接器连接集群队列管理器时。但是当我将JMS连接器更改为引用本地队列管理器时，它完全正常运行... - Sambit Swain

没有使用Mule请求器和集群队列，它是否能正常工作？ - aled

是的，jms:inbound-endpoint（即没有mulerequester）可以很好地与集群队列配合使用。但是使用mulerequester时，我只能连接到本地队列。 - Sambit Swain

我们有一个 jms:selector 来过滤队列中的消息，但我不能在流程中间使用它。这就是为什么我更喜欢 mulerequester。 但是，非常感谢您的帮助，您关于未注册端点的线索实际上很有帮助。 - Sambit Swain