diff --git a/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java b/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java
index dbc942517..baa99b302 100644
--- a/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java
+++ b/app/src/main/java/com/nextcloud/talk/activities/CallActivity.java
@@ -1624,7 +1624,7 @@ public class CallActivity extends CallBaseActivity {
                 break;
             case "signalingMessage":
                 Log.d(TAG, "onMessageEvent 'signalingMessage'");
-                processMessage((NCSignalingMessage) webSocketClient.getJobWithId(
+                signalingMessageReceiver.process((NCSignalingMessage) webSocketClient.getJobWithId(
                     Integer.valueOf(webSocketCommunicationEvent.getHashMap().get("jobId"))));
                 break;
             case "peerReadyForRequestingOffer":
@@ -1670,17 +1670,9 @@ public class CallActivity extends CallBaseActivity {
         } else if ("message".equals(messageType)) {
             NCSignalingMessage ncSignalingMessage = LoganSquare.parse(signaling.getMessageWrapper().toString(),
                                                                       NCSignalingMessage.class);
-            processMessage(ncSignalingMessage);
-        } else {
-            Log.e(TAG, "unexpected message type when receiving signaling message");
-        }
-    }
-
-    private void processMessage(NCSignalingMessage ncSignalingMessage) {
-        if ("video".equals(ncSignalingMessage.getRoomType()) || "screen".equals(ncSignalingMessage.getRoomType())) {
             signalingMessageReceiver.process(ncSignalingMessage);
         } else {
-            Log.e(TAG, "unexpected RoomType while processing NCSignalingMessage");
+            Log.e(TAG, "unexpected message type when receiving signaling message");
         }
     }