Spring/WebLogic - сообщение JMS не доставляется повторно при сбое

Я использую WerbLogic 10.3.5 и Spring 3.0 для реализации очереди JMS. У меня есть следующая конфигурация Spring:

    <!--  JMS Configuration -->
<bean id="paymentlistener" class="com.myproject.service.impl.PaymentListener"/> 

<bean id="paymentlistenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="concurrentConsumers" value="10"/>
    <property name="connectionFactory" ref="paymentConnectionFactory"/>
    <property name="destination" ref="paymentQueue"/>
    <property name="messageListener" ref="paymentlistener"/>
</bean>

<bean id="paymentQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="jms/paymentResponseHandlerQueue"/>
    <property name="jndiTemplate" ref="jndiTemplate"/>
</bean>

<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
    <property name="environment">
        <props>
            <prop key="java.naming.factory.initial">weblogic.jndi.WLInitialContextFactory</prop>
            <prop key="java.naming.provider.url">t3://localhost:7001</prop>
        </props>
    </property>
</bean>

<bean id="paymentConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate" ref="jndiTemplate"/>
    <property name="jndiName" value="jms/paymentResponseHandlerConnectionFactory"/>
</bean>

<bean id="jmsDestinationResolver" class="org.springframework.jms.support.destination.JndiDestinationResolver">
    <property name="jndiTemplate" ref="jndiTemplate"/>
    <property name="cache" value="true"/>
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="paymentConnectionFactory"/>
    <property name="destinationResolver" ref="jmsDestinationResolver"/>
    <property name="defaultDestination" ref="paymentQueue"/>
    <property name="sessionAcknowledgeModeName" value="DUPS_OK_ACKNOWLEDGE"/>
    <property name="sessionTransacted" value="true"/>
</bean>

Мой код создания сообщения выглядит так:

    MessageCreator messageCreator = new MessageCreator() {
        public Message createMessage(Session session) throws JMSException {
                logger.debug("Session ack mode: " + session.getAcknowledgeMode());
                return session.createObjectMessage(payment);
        }
    };


    jmsTemplate.send("jms/paymentResponseHandlerQueue", messageCreator);

И мой слушатель выглядит так:

@Override
public void onMessage(Message message) { // , Session session
if (!(message instanceof ObjectMessage)) {
    throw new IllegalStateException("The PaymentListener queue expects an object message"); 
}

ObjectMessage objectMessage = (ObjectMessage) message;

try {
    logger.debug("Is Message redelivered:" + objectMessage.getJMSRedelivered ());

    if (objectMessage.getObject() instanceof CreditCardPaymentDTO) {

        logger.debug("Object is of type CreditCardPaymentDTO");

        // The user that just logged in
        CreditCardPaymentDTO payment  = (CreditCardPaymentDTO) objectMessage.getObject();               
        otpCollectorDAO.savePayment(payment);
    }
} catch (JMSException e) {
    logger.error(e);
    throw new RuntimeException(e);
} catch (PaymentResponseException e) {
    logger.error(e);
    throw new RuntimeException(e);
}
}

Сообщение создается правильно, и вызывается метод onMessage() моего слушателя, но если логика дает сбой и я выбрасываю RuntimeException(), сообщение не доставляется повторно. Я пробовал множество небольших вариаций приведенного выше кода (например, установка sessionAcknowledgeModeName=SESSION_TRANSACTED и явный откат транзакции), но сообщение никогда не помещается в очередь повторно. В чем хитрость повторной доставки ошибочных сообщений?


person freecouch    schedule 19.06.2014    source источник
comment
Вы пытались установить sessionTransacted в true для DefaultMessageListenerContainer?   -  person Andrei Stefan    schedule 20.06.2014
comment
Вот оно. Если вы предоставите это как ответ, я приму это. СПАСИБО!   -  person freecouch    schedule 20.06.2014
comment
:-) круто, рад, что теперь работает.   -  person Andrei Stefan    schedule 20.06.2014


Ответы (1)


Я считаю, что вам нужно установить sessionTransacted на true для DefaultMessageListenerContainer:

<bean id="paymentlistenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    ...
    <property name="sessionTransacted" value="true"/>
</bean>

Вы можете найти здесь соответствующую справочную документацию.

person Andrei Stefan    schedule 20.06.2014