You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@cocoon.apache.org by un...@apache.org on 2005/06/27 13:15:05 UTC

svn commit: r201968 - /cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessageListener.java

Author: unico
Date: Mon Jun 27 04:15:02 2005
New Revision: 201968

URL: http://svn.apache.org/viewcvs?rev=201968&view=rev
Log:
it seems the session must be recovered when reconnecting

Modified:
    cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessageListener.java

Modified: cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessageListener.java
URL: http://svn.apache.org/viewcvs/cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessageListener.java?rev=201968&r1=201967&r2=201968&view=diff
==============================================================================
--- cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessageListener.java (original)
+++ cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessageListener.java Mon Jun 27 04:15:02 2005
@@ -180,6 +180,8 @@
                 m_subscriber = m_session.createSubscriber(topic, m_selector, false);
             }
             m_subscriber.setMessageListener(this);
+            // recover in case of reconnection
+            m_session.recover();
         }
         else {
             if (getLogger().isWarnEnabled()) {