You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openmeetings.apache.org by so...@apache.org on 2020/05/18 16:23:25 UTC
[openmeetings] branch master updated: [OPENMEETINGS-2355] listeners
are cleaned-up
This is an automated email from the ASF dual-hosted git repository.
solomax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/openmeetings.git
The following commit(s) were added to refs/heads/master by this push:
new 52cae0f [OPENMEETINGS-2355] listeners are cleaned-up
52cae0f is described below
commit 52cae0ff6398b6614496165d0e15d1be14854be9
Author: Maxim Solodovnik <so...@gmail.com>
AuthorDate: Mon May 18 23:23:08 2020 +0700
[OPENMEETINGS-2355] listeners are cleaned-up
---
.../main/java/org/apache/openmeetings/core/remote/StreamProcessor.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/StreamProcessor.java b/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/StreamProcessor.java
index 729e77a..f8a1138 100644
--- a/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/StreamProcessor.java
+++ b/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/StreamProcessor.java
@@ -506,6 +506,7 @@ public class StreamProcessor implements IStreamProcessor {
}
}
if (c.getRoomId() != null) {
+ getByRoom(c.getRoomId()).stream().forEach(stream -> stream.remove(c)); // listeners of existing streams should be cleaned-up
checkStreams(c.getRoomId());
}
}