You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2012/03/08 22:46:23 UTC
svn commit: r1298600 - in
/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra:
QpidRASession.java QpidRASessionFactory.java QpidRASessionFactoryImpl.java
QpidRASessionImpl.java
Author: rajith
Date: Thu Mar 8 21:46:22 2012
New Revision: 1298600
URL: http://svn.apache.org/viewvc?rev=1298600&view=rev
Log:
QPID-3806 Committing a patch by Weston Price.
Modified:
qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASession.java
qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactory.java
qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactoryImpl.java
qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionImpl.java
Modified: qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASession.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASession.java?rev=1298600&r1=1298599&r2=1298600&view=diff
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASession.java (original)
+++ qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASession.java Thu Mar 8 21:46:22 2012
@@ -30,4 +30,6 @@ public interface QpidRASession
public void start() throws JMSException;
public void close() throws JMSException;
+
+ public void closeSession() throws JMSException;
}
Modified: qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactory.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactory.java?rev=1298600&r1=1298599&r2=1298600&view=diff
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactory.java (original)
+++ qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactory.java Thu Mar 8 21:46:22 2012
@@ -58,5 +58,5 @@ public interface QpidRASessionFactory ex
* @param session The session
* @throws JMSException for any error
*/
- void closeSession(QpidRASessionImpl session) throws JMSException;
+ void closeSession(QpidRASession session) throws JMSException;
}
Modified: qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactoryImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactoryImpl.java?rev=1298600&r1=1298599&r2=1298600&view=diff
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactoryImpl.java (original)
+++ qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionFactoryImpl.java Thu Mar 8 21:46:22 2012
@@ -567,7 +567,7 @@ public class QpidRASessionFactoryImpl im
_started = true;
for (Iterator<QpidRASession> i = _sessions.iterator(); i.hasNext();)
{
- QpidRASessionImpl session = (QpidRASessionImpl)i.next();
+ QpidRASession session = (QpidRASession)i.next();
session.start();
}
}
@@ -609,7 +609,7 @@ public class QpidRASessionFactoryImpl im
{
for (Iterator<QpidRASession> i = _sessions.iterator(); i.hasNext();)
{
- QpidRASessionImpl session = (QpidRASessionImpl)i.next();
+ QpidRASession session = (QpidRASession)i.next();
try
{
session.closeSession();
@@ -670,7 +670,7 @@ public class QpidRASessionFactoryImpl im
* @param session The session
* @exception JMSException Thrown if an error occurs
*/
- public void closeSession(final QpidRASessionImpl session) throws JMSException
+ public void closeSession(final QpidRASession session) throws JMSException
{
if (_log.isTraceEnabled())
{
@@ -679,7 +679,7 @@ public class QpidRASessionFactoryImpl im
synchronized (_sessions)
{
- _sessions.remove(session);
+ _sessions.clear();
}
}
Modified: qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionImpl.java?rev=1298600&r1=1298599&r2=1298600&view=diff
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionImpl.java (original)
+++ qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRASessionImpl.java Thu Mar 8 21:46:22 2012
@@ -1446,7 +1446,7 @@ public class QpidRASessionImpl implement
* Close session
* @exception JMSException Thrown if an error occurs
*/
- void closeSession() throws JMSException
+ public void closeSession() throws JMSException
{
final QpidRAManagedConnection mc = this._mc;
if (mc != null)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org