allow disconnecting from disposed message bus (EA-33973 - assert: MessageBusImpl.checkNotDisposed)

This commit is contained in:
Dmitry Jemerov
2012-02-23 14:29:35 +01:00
parent 1500a4793e
commit bcfcf721a4
@@ -1,5 +1,5 @@
/*
* Copyright 2000-2009 JetBrains s.r.o.
* Copyright 2000-2012 JetBrains s.r.o.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -239,10 +239,10 @@ public class MessageBusImpl implements MessageBus {
}
public void notifyConnectionTerminated(final MessageBusConnectionImpl connection) {
checkNotDisposed();
for (List<MessageBusConnectionImpl> topicSubscribers : mySubscribers.values()) {
topicSubscribers.remove(connection);
}
if (myDisposed) return;
final Iterator<DeliveryJob> i = myMessageQueue.get().iterator();
while (i.hasNext()) {