diff --git a/app/src/main/java/org/unifiedpush/distributor/nextpush/api/SSEListener.kt b/app/src/main/java/org/unifiedpush/distributor/nextpush/api/SSEListener.kt
index b23d511..c88e066 100644
--- a/app/src/main/java/org/unifiedpush/distributor/nextpush/api/SSEListener.kt
+++ b/app/src/main/java/org/unifiedpush/distributor/nextpush/api/SSEListener.kt
@@ -65,6 +65,7 @@ class SSEListener(val context: Context) : EventSourceListener() {
     }
 
     override fun onClosed(eventSource: EventSource) {
+        eventSource.cancel()
         if (!StartService.isServiceStarted) {
             return
         }
@@ -74,6 +75,7 @@ class SSEListener(val context: Context) : EventSourceListener() {
     }
 
     override fun onFailure(eventSource: EventSource, t: Throwable?, response: Response?) {
+        eventSource.cancel()
         if (!StartService.isServiceStarted) {
             return
         }