|
@@ -103,10 +103,7 @@ public class MQTTClient : MonoSingleton<MQTTClient>
|
|
|
if (username != null)
|
|
|
this.username = username;
|
|
|
}
|
|
|
- public void SetSceneID(string id)
|
|
|
- {
|
|
|
- rid = id;
|
|
|
- }
|
|
|
+
|
|
|
|
|
|
|
|
|
public void Connect()
|
|
@@ -148,11 +145,11 @@ public class MQTTClient : MonoSingleton<MQTTClient>
|
|
|
|
|
|
public void Subscribe()
|
|
|
{
|
|
|
- Debug.Log(" DGJ =====> Subscribe " + UserInfo.Instance.name);
|
|
|
+ Debug.Log(" DGJ =====> Subscribe "+ id);
|
|
|
ushort s = qt.Subscribe(
|
|
|
new string[]
|
|
|
{
|
|
|
- front+rid
|
|
|
+ id
|
|
|
|
|
|
},
|
|
|
new byte[]
|
|
@@ -220,7 +217,7 @@ public class MQTTClient : MonoSingleton<MQTTClient>
|
|
|
|
|
|
void publish(byte[] bs)
|
|
|
{
|
|
|
- Debug.Log("DGJ publish =====> " +bs.Length);
|
|
|
- qt.Publish(front + rid, bs, MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
|
|
|
+ Debug.Log(id+" DGJ publish =====> " + rid+" " + bs.Length);
|
|
|
+ qt.Publish(rid, bs, MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
|
|
|
}
|
|
|
}
|