mirror of https://github.com/apache/activemq.git
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.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@378014 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
a8dfa1f41b
commit
6f99fe8271
|
@ -507,9 +507,8 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
|
|||
connection.asyncSendPacket(info.createRemoveCommand());
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void dispose() throws JMSException {
|
||||
synchronized public void dispose() throws JMSException {
|
||||
if (!closed) {
|
||||
|
||||
for (Iterator iter = consumers.iterator(); iter.hasNext();) {
|
||||
|
|
Loading…
Reference in New Issue