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