带有 JMS 连接器的 mule 请求器模块

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 文档中的定义进行了操作

Answer 1

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

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