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 <[email protected]>
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());
                }
        }

Reply via email to