fix bug of msgbody convert byte

This commit is contained in:
zhongchao
2021-02-22 11:29:04 +08:00
parent f8baf1282f
commit 74ca0dfe19
3 changed files with 5 additions and 5 deletions

View File

@@ -23,7 +23,7 @@ public class MsgBody {
/**
* 消息内容
*/
private Object mContent;
private byte[] mContent;
public MsgBody msgType(int msgType) {
this.mMsgType = msgType;
@@ -35,7 +35,7 @@ public class MsgBody {
return this;
}
public MsgBody content(Object object) {
public MsgBody content(byte[] object) {
this.mContent = object;
return this;
}
@@ -52,7 +52,7 @@ public class MsgBody {
return mMsgId;
}
public Object getContent() {
public byte[] getContent() {
return mContent;
}
}

View File

@@ -120,7 +120,7 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
@Override
public void sendMsg(String appId, int headerType, MsgBody body, IMogoCloudSocketMsgAckListener listener) {
Logger.d(TAG, "sendMsg msgId : " + body.getMsgId());
final byte[] pb = convertToPBBytes(body.getMsgType(), body.getContent().toString().getBytes());
final byte[] pb = convertToPBBytes(body.getMsgType(), body.getContent());
SocketClient.getInstance().sendData(appId, MogoCommon.Product.mogoBussiness.getNumber(), pb, headerType, true, body.getMsgId());
mAckListeners.put(body.getMsgId(), listener);
}

View File

@@ -188,7 +188,7 @@ public class SocketHandler {
}
MsgBody msgBody = new MsgBody();
msgBody.msgType(msgType);
msgBody.content(msg);
msgBody.content(msg.getBytes());
SocketManager.getInstance().sendMsg(mAppId, HEADER_TYPE, msgBody, msgId -> {
for (IMogoCloudOnMsgListener listener : onMsgListenerList) {
if (listener != null) {