BPK session close fix

kaltura · Jan 9, 2024 · 3725817 · 3725817
1 parent fa7efe6
commit 3725817
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/broadpeakplugin/src/main/java/com/kaltura/playkit/plugins/broadpeak/BroadpeakPlugin.java b/broadpeakplugin/src/main/java/com/kaltura/playkit/plugins/broadpeak/BroadpeakPlugin.java
@@ -228,7 +228,6 @@ public void apply(PKMediaEntry mediaEntry, PKMediaEntryInterceptor.Listener list
                 sendBroadpeakErrorEvent(errorCode, errorMessage);
                 return;
             }
-            sessionsMap.put(source.getUrl(), session);
 
             addSessionConfig(session);
             session.attachPlayer(player, messageBus);
@@ -238,7 +237,6 @@ public void apply(PKMediaEntry mediaEntry, PKMediaEntryInterceptor.Listener list
                 sendSourceUrlSwitchedEvent(source, result);
 
                 // Replace the URL
-                sessionsMap.remove(source.getUrl());
                 log.d("Apply New Entry URL  " + mediaEntry.getName() + " - " + mediaEntry.getId() + " url: " + result.getURL());
                 source.setUrl(result.getURL());
                 sessionsMap.put(source.getUrl(), session);
@@ -248,7 +246,7 @@ public void apply(PKMediaEntry mediaEntry, PKMediaEntryInterceptor.Listener list
                     errorCode = result.getErrorCode();
                     errorMessage = result.getErrorMessage();
                 }
-                stopStreamingSession(source.getUrl());
+                session.stopStreamingSession();
                 // send event to MessageBus
                 sendBroadpeakErrorEvent(errorCode, errorMessage);
             }