code: @Override
      public void onControlMessageArrived(String deviceId, String appTopic, KuraPayload msg, int qos, boolean retain) {
          onInternalMessageArrived(deviceId, appTopic, msg, qos, retain, true);
      }
docs: CloudClientListener callbacks