diff --git a/bbb-apps-common/src/main/scala/org/bigbluebutton/client/MsgToClientJsonActor.scala b/bbb-apps-common/src/main/scala/org/bigbluebutton/client/MsgToClientJsonActor.scala
index 98b294b8ab096fc2894f027b9511cf3d52568935..6f1d780a5c2b9a1fa4043542fcc0757363bb7c7c 100755
--- a/bbb-apps-common/src/main/scala/org/bigbluebutton/client/MsgToClientJsonActor.scala
+++ b/bbb-apps-common/src/main/scala/org/bigbluebutton/client/MsgToClientJsonActor.scala
@@ -46,14 +46,14 @@ class MsgToClientJsonActor(msgToClientGW: MsgToClientGW) extends Actor with Acto
   def handleSystemMsg(msg: SystemMsgToClient): Unit = {
     println("Received SystemMsgToClient " + msg)
     val meetingId = msg.meetingId
-    val connId = msg.connId
+    val userId = msg.userId
 
     msg.data.envelope.name match {
       case DisconnectAllClientsSysMsg.NAME =>
         val disconnect = new DisconnectAllClientsMessage(meetingId)
         msgToClientGW.systemMessage(disconnect)
       case DisconnectClientSysMsg.NAME =>
-        val disconnect = new DisconnectClientMessage(meetingId, connId)
+        val disconnect = new DisconnectClientMessage(meetingId, userId)
         msgToClientGW.systemMessage(disconnect)
     }
   }
diff --git a/bbb-apps-common/src/main/scala/org/bigbluebutton/client/bus/MsgToClientEventBus.scala b/bbb-apps-common/src/main/scala/org/bigbluebutton/client/bus/MsgToClientEventBus.scala
index 4aee1fec5b5e2c50e7dfa010669f6bd4646e3066..96f036da507ee1e2c1db3b92c9c48f9beb9134eb 100755
--- a/bbb-apps-common/src/main/scala/org/bigbluebutton/client/bus/MsgToClientEventBus.scala
+++ b/bbb-apps-common/src/main/scala/org/bigbluebutton/client/bus/MsgToClientEventBus.scala
@@ -7,7 +7,7 @@ import org.bigbluebutton.common2.msgs.BbbCommonEnvJsNodeMsg
 sealed trait ToConnectionMsg
 case class BroadcastMsgToMeeting(meetingId: String, data: BbbCommonEnvJsNodeMsg) extends ToConnectionMsg
 case class DirectMsgToClient(meetingId: String, connId: String, data: BbbCommonEnvJsNodeMsg) extends ToConnectionMsg
-case class SystemMsgToClient(meetingId: String, connId: String, data: BbbCommonEnvJsNodeMsg) extends ToConnectionMsg
+case class SystemMsgToClient(meetingId: String, userId: String, data: BbbCommonEnvJsNodeMsg) extends ToConnectionMsg
 
 case class MsgToClientBusMsg(val topic: String, payload: ToConnectionMsg)
 
diff --git a/bbb-apps-common/src/main/scala/org/bigbluebutton/client/meeting/UserActor.scala b/bbb-apps-common/src/main/scala/org/bigbluebutton/client/meeting/UserActor.scala
index d12f64dd6f76de703a1f47f46a4d7c638cd8b0a4..6a2dd14897f5d82ed6092cb1283429f99557bfd8 100755
--- a/bbb-apps-common/src/main/scala/org/bigbluebutton/client/meeting/UserActor.scala
+++ b/bbb-apps-common/src/main/scala/org/bigbluebutton/client/meeting/UserActor.scala
@@ -147,26 +147,11 @@ class UserActor(val userId: String,
   }
 
   def handleSystemMessage(msg: BbbCommonEnvJsNodeMsg): Unit = {
-    for {
-      conn <- Connections.findActiveConnection(conns)
-    } yield {
-      // val json = JsonUtil.toJson(msg.core)
-
-      msg.envelope.name match {
-        case DisconnectClientSysMsg.NAME => handleDisconnectClientSysMsg(msg)
-        case _ => {
-          msgToClientEventBus.publish(MsgToClientBusMsg(toClientChannel, SystemMsgToClient(meetingId, conn.connId, msg)))
-        }
-      }
-    }
-  }
-
-  def handleDisconnectClientSysMsg(msg: BbbCommonEnvJsNodeMsg): Unit = {
     for {
       userId <- msg.envelope.routing.get("userId")
     } yield {
-      // Note - we use userId rather than connId for DisconnectClientSysMsg
       msgToClientEventBus.publish(MsgToClientBusMsg(toClientChannel, SystemMsgToClient(meetingId, userId, msg)))
     }
   }
+
 }