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()) {