|
@@ -11,9 +11,12 @@ import org.eclipse.paho.client.mqttv3.MqttMessage;
|
|
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
|
|
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
|
|
|
|
|
|
import cn.org.bjca.trust.android.lib.im.cfg.Constant;
|
|
import cn.org.bjca.trust.android.lib.im.cfg.Constant;
|
|
|
|
+import cn.org.bjca.trust.android.lib.im.common.DeviceHelper;
|
|
import cn.org.bjca.trust.android.lib.im.common.json.GsonImplHelp;
|
|
import cn.org.bjca.trust.android.lib.im.common.json.GsonImplHelp;
|
|
import cn.org.bjca.trust.android.lib.im.im.bean.PacketMessage;
|
|
import cn.org.bjca.trust.android.lib.im.im.bean.PacketMessage;
|
|
import cn.org.bjca.trust.android.lib.im.im.kit.IMInterface;
|
|
import cn.org.bjca.trust.android.lib.im.im.kit.IMInterface;
|
|
|
|
+import cn.org.bjca.trust.android.lib.im.im.msg.ConnectMessage;
|
|
|
|
+import cn.org.bjca.trust.android.lib.im.im.msg.SZYXMessage;
|
|
import cn.org.bjca.trust.android.lib.im.im.opt.ImConnectOptions;
|
|
import cn.org.bjca.trust.android.lib.im.im.opt.ImConnectOptions;
|
|
import cn.org.bjca.trust.android.lib.im.kit.IMSDKCallback;
|
|
import cn.org.bjca.trust.android.lib.im.kit.IMSDKCallback;
|
|
import cn.org.bjca.trust.android.lib.im.kit.IMSDKListener;
|
|
import cn.org.bjca.trust.android.lib.im.kit.IMSDKListener;
|
|
@@ -81,6 +84,8 @@ public class ImManager implements IMInterface {
|
|
} catch (MqttException e) {
|
|
} catch (MqttException e) {
|
|
Log.e(TAG, "=====>connectComplete", e);
|
|
Log.e(TAG, "=====>connectComplete", e);
|
|
}
|
|
}
|
|
|
|
+ // 发送登录消息
|
|
|
|
+ sendConnectMsg();
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -140,6 +145,16 @@ public class ImManager implements IMInterface {
|
|
return this.status == 1;
|
|
return this.status == 1;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public void sendSZYXMessage(SZYXMessage message, IMSDKCallback callback) {
|
|
|
|
+ sendPacketMessage(message, callback);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void sendConnectMsg() {
|
|
|
|
+ ConnectMessage message = new ConnectMessage(DeviceHelper.getDevice());
|
|
|
|
+ sendPacketMessage(message, null);
|
|
|
|
+ }
|
|
|
|
+
|
|
private void sendPacketMessage(PacketMessage message, IMSDKCallback callback) {
|
|
private void sendPacketMessage(PacketMessage message, IMSDKCallback callback) {
|
|
if (null == connectOptions) {
|
|
if (null == connectOptions) {
|
|
if (null != callback) callback.failed(204, "未登录");
|
|
if (null != callback) callback.failed(204, "未登录");
|
|
@@ -153,7 +168,7 @@ public class ImManager implements IMInterface {
|
|
try {
|
|
try {
|
|
mqttClient.publish("server", msg.getBytes(Charsets.UTF_8), 2, false);
|
|
mqttClient.publish("server", msg.getBytes(Charsets.UTF_8), 2, false);
|
|
} catch (MqttException e) {
|
|
} catch (MqttException e) {
|
|
-
|
|
|
|
|
|
+ if (null != callback) callback.failed(206, e.getMessage());
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|