Spring MDP не потребляет сообщения

Я реализую Spring MDP + JMSTemplate для отправки и получения сообщения. Механизм отправки сообщений работает нормально, однако MDP не вызывается. Я попытался протестировать через обычный приемник и смог получить сообщение, но не через MDP. В чем может быть проблема? Я вижу, как сообщения накапливаются в очереди запросов, но MDP почему-то не получает триггер. Я что-то здесь упускаю в конфигурациях или о чем-то еще нужно позаботиться?

Вот весенний конфиг. Класс 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>

0 ответов

Другие вопросы по тегам