1

我正在实现 Spring MDP + JMSTemplate 来发送和接收消息。消息发送机制工作正常，但是没有调用 MDP。我尝试测试通过普通接收器，并且能够检索消息，但不能通过 MDP。可能是什么问题呢？我可以看到消息在请求队列中累积，但不知何故 MDP 没有被触发。我是否在配置中遗漏了任何内容或需要注意其他事项？

这是 Spring 配置。发送和接收的 Java 类几乎是标准的。

    <bean id="cookieRequestListener" class="com.text.jms.mq.mdp.RequestQueueMDP">
        <property name="logger" ref="mqLogger" />
        <property name="scoringEngine" ref="scoringEngine" />
        <property name="mqSender" ref="jmsMQSender" />
        </bean>

    <bean id="CookieRequestContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="cachedConnectionFactory" />
        <property name="destination" ref="jmsRequestQueue" />
        <property name="messageListener" ref="cookieRequestListener" />
    </bean>

    <bean id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate">
            <ref bean="jndiTemplate" />
        </property>
        <property name="jndiName">
            <value>java:/jms/queueCF</value>
        </property>
    </bean>

    <!-- A cached connection to wrap the Queue connection -->
    <bean id="cachedConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
        <property name="targetConnectionFactory" ref="jmsConnectionFactory"/>
        <property name="sessionCacheSize" value="10" />
    </bean>


    <!-- jms Request Queue Configuration -->
    <bean id="jmsRequestQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate">
            <ref bean="jndiTemplate" />
        </property>
        <property name="jndiName">
            <value>java:/jms/cookieReqQ</value>
        </property>
    </bean>

    <!-- jms Response Queue Configuration -->
    <bean id="jmsResponseQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate">
            <ref bean="jndiTemplate" />
        </property>
        <property name="jndiName">
            <value>java:/jms/cookieResQ</value>
        </property>
    </bean>

    <bean id="jmsJMSTemplate" class="org.springframework.jms.core.JmsTemplate" >
        <property name="connectionFactory" ref="cachedConnectionFactory" />
    </bean>

    <!-- jms MQ Utility -->
    <bean id="jmsMQSender" class="com.text.jms.util.MQSender">
        <property name="jmsTemplate">
            <ref bean="jmsJMSTemplate"></ref>
        </property>
        <property name="defaultDestination">
            <ref bean="jmsRequestQueue" />
        </property>
        <property name="logger" ref="mqLogger" />
    </bean>
4

0 回答 0