0

ラバの簡単なセットアップができました。JMS キュー処理メッセージから読み取り、例外が発生した場合は DLQ に送信します。Mule 3.3.0 および HornetQ 2.3.0.BETA1 を使用。次の例外が発生しています：

Caused by: java.lang.ClassCastException: org.mule.transport.jms.ReusableTopicSessionWrapper cannot be cast to javax.jms.QueueSession
    at org.mule.transport.jms.Jms102bSupport.createDestination(Jms102bSupport.java:231)
    at org.mule.transport.jms.Jms11Support.createDestination(Jms11Support.java:142)
    at org.mule.transport.jms.JmsMessageDispatcher.dispatchMessage(JmsMessageDispatcher.java:163)
    at org.mule.transport.jms.JmsMessageDispatcher.doDispatch(JmsMessageDispatcher.java:81)
    at org.mule.transport.AbstractMessageDispatcher.process(AbstractMessageDispatcher.java:99)
    ... 113 more

私のセットアップ：

    <jms:connector name="connector.jms" maxRedelivery="10"  doc:name="JMS"

        jndiInitialFactory="org.jnp.interfaces.NamingContextFactory"
        jndiProviderUrl="jnp://localhost:1099"
        connectionFactoryJndiName="ConnectionFactory"
        createMultipleTransactedReceivers="true"
        numberOfConcurrentTransactedReceivers="100"
        acknowledgementMode="AUTO_ACKNOWLEDGE">
    <reconnect-forever frequency="5000"/>       
</jms:connector>
<flow name="jmsListenerFlow1" doc:name="jmsListenerFlow1">
    <jms:inbound-endpoint queue="adsLogQueue" connector-ref="connector.jms" doc:name="JMS">
        <jms:transaction action="ALWAYS_BEGIN"/>
    </jms:inbound-endpoint>
    <component >
        <spring-object bean="logSaver"/>
    </component>
    <catch-exception-strategy>
        <jms:outbound-endpoint queue="DLQ"> <!-- [2] -->
            <jms:transaction action="ALWAYS_JOIN" />
        </jms:outbound-endpoint>            
    </catch-exception-strategy>
</flow>

Mule自体のバグでしょうか？それとも私は何か間違ったことをしていますか？

4

1 に答える 1

0

に設定specification="1.1"しますjms:connector。

于 2012-11-02T15:30:32.967 に答える