activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r378014 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
Date Wed, 15 Feb 2006 14:57:47 GMT
Author: chirino
Date: Wed Feb 15 06:57:46 2006
New Revision: 378014

URL: http://svn.apache.org/viewcvs?rev=378014&view=rev
Log:
Nullpointer exception could occur is the session is being closed at the same time that an
async exception is received since it would also close the session out at the same time.

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java?rev=378014&r1=378013&r2=378014&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
Wed Feb 15 06:57:46 2006
@@ -507,9 +507,8 @@
             connection.asyncSendPacket(info.createRemoveCommand());
         }
     }
-    
 
-    public void dispose() throws JMSException {
+    synchronized public void dispose() throws JMSException {
         if (!closed) {
             
             for (Iterator iter = consumers.iterator(); iter.hasNext();) {



Mime
View raw message