|
@@ -66,6 +66,8 @@ public class ImManager implements IMInterface {
|
|
@Override
|
|
@Override
|
|
public void connectComplete(boolean reconnect, String serverURI) {
|
|
public void connectComplete(boolean reconnect, String serverURI) {
|
|
Log.e("======>connectComplete", reconnect + "::" + serverURI);
|
|
Log.e("======>connectComplete", reconnect + "::" + serverURI);
|
|
|
|
+ status = 0;
|
|
|
|
+ if (reconnect) return;
|
|
try {
|
|
try {
|
|
mqttClient.subscribe(Constant.getSdkAppID() + "/message" + Constant.getUserId(), 2);
|
|
mqttClient.subscribe(Constant.getSdkAppID() + "/message" + Constant.getUserId(), 2);
|
|
mqttClient.subscribe(Constant.getSdkAppID() + "/pang" + Constant.getUserId(), 2);
|
|
mqttClient.subscribe(Constant.getSdkAppID() + "/pang" + Constant.getUserId(), 2);
|