diff --git a/app/src/main/java/org/unifiedpush/distributor/nextpush/services/FailureHandler.kt b/app/src/main/java/org/unifiedpush/distributor/nextpush/services/FailureHandler.kt
index 4e70312..b7ec9c1 100644
--- a/app/src/main/java/org/unifiedpush/distributor/nextpush/services/FailureHandler.kt
+++ b/app/src/main/java/org/unifiedpush/distributor/nextpush/services/FailureHandler.kt
@@ -14,7 +14,7 @@ interface FailureHandler {
     // This is the last eventSource opened
     var eventSource: EventSource?
 
-    fun newEvent(context: Context, eventSource: EventSource) {
+    fun newEventSource(context: Context, eventSource: EventSource) {
         Log.d(TAG,"newEvent/Eventsource: $eventSource")
         this.eventSource = eventSource
         nFails = 0
diff --git a/app/src/main/java/org/unifiedpush/distributor/nextpush/services/SSEListener.kt b/app/src/main/java/org/unifiedpush/distributor/nextpush/services/SSEListener.kt
index a20271f..1d679fe 100644
--- a/app/src/main/java/org/unifiedpush/distributor/nextpush/services/SSEListener.kt
+++ b/app/src/main/java/org/unifiedpush/distributor/nextpush/services/SSEListener.kt
@@ -24,7 +24,7 @@ class SSEListener (val context: Context) : EventSourceListener() {
     }
 
     override fun onOpen(eventSource: EventSource, response: Response) {
-        StartService.newEvent(context, eventSource)
+        StartService.newEventSource(context, eventSource)
         StartService.wakeLock?.let {
             while (it.isHeld) {
                 it.release()