Skip to content

Commit 2261bcc

Browse files
committed
fixed:header protocol field incorrect when unread message reply
1 parent b9bfd9b commit 2261bcc

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

XEngine_Source/MQCore_ProtocolModule/ProtocolModule_Packet/ProtocolModule_Packet.cpp

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -641,13 +641,20 @@ XHANDLE CProtocolModule_Packet::ProtocolModule_Packet_UNReadCreate(XENGINE_PROTO
641641
pSt_UNRead->nType = enPayType;
642642
if (pSt_UNRead->nType == ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_BIN)
643643
{
644+
pSt_UNRead->st_ProtocolHdr.wHeader = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_HEADER;
645+
pSt_UNRead->st_ProtocolHdr.wTail = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_TAIL;
646+
pSt_UNRead->st_ProtocolHdr.unOperatorType = ENUM_XENGINE_COMMUNICATION_PROTOCOL_TYPE_XMQ;
647+
pSt_UNRead->st_ProtocolHdr.unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPUNREAD;
644648
pSt_UNRead->st_ProtocolHdr.byVersion = ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_JSON;
645649
}
646650
else
647651
{
652+
pSt_UNRead->st_JsonRoot["wHeader"] = pSt_ProtocolHdr->wHeader;
653+
pSt_UNRead->st_JsonRoot["wTail"] = pSt_ProtocolHdr->wTail;
648654
pSt_UNRead->st_JsonRoot["unOperatorType"] = pSt_ProtocolHdr->unOperatorType;
649655
pSt_UNRead->st_JsonRoot["unOperatorCode"] = pSt_ProtocolHdr->unOperatorCode;
650-
pSt_UNRead->st_JsonRoot["wReserve"] = pSt_ProtocolHdr->wReserve;
656+
pSt_UNRead->st_JsonRoot["byVersion"] = ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_JSON;
657+
pSt_UNRead->st_JsonRoot["wReserve"] = 0;
651658
}
652659
return pSt_UNRead;
653660
}

0 commit comments

Comments
 (0)