improved:reply message protocol set

xengine-qyt · xengine-qyt · commit cc8fd6f54c4a · 2025-08-28T13:44:55.000+08:00
diff --git a/XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp b/XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp
@@ -312,6 +312,7 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 			}
 			else if (0 == st_MQProtocol.nPubTime)
 			{
+				pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;
 				//设置为0,不是定时发布,即时通知
 				if (1 == st_MQProtocol.st_MSGAttr.byAttrAll)
 				{
@@ -329,8 +330,6 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 						int nClientType = 0;
 						memset(tszSDBuffer, '\0', sizeof(tszSDBuffer));
 
-						pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;
-
 						SessionModule_Client_GetType(pptszListAddr[i], &nClientType);
 						ProtocolModule_Packet_Common(nClientType, pSt_ProtocolHdr, &st_MQProtocol, tszSDBuffer, &nSDLen, lpszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), nMsgLen - sizeof(XENGINE_PROTOCOL_XMQ));
 						XEngine_MQXService_Send(pptszListAddr[i], tszSDBuffer, nSDLen, nClientType);
@@ -339,8 +338,6 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 				}
 				else
 				{
-					pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;
-
 					if (_tcsxlen(st_MQProtocol.tszMQUsr) > 0)
 					{
 						//如果发送指定用户被指定.

Original file line number	Diff line number	Diff line change
`@@ -312,6 +312,7 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC`
`312`	`312`	`}`
`313`	`313`	`else if (0 == st_MQProtocol.nPubTime)`
`314`	`314`	`{`
	`315`	`+ pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;`
`315`	`316`	`//设置为0,不是定时发布,即时通知`
`316`	`317`	`if (1 == st_MQProtocol.st_MSGAttr.byAttrAll)`
`317`	`318`	`{`
`@@ -329,8 +330,6 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC`
`329`	`330`	`int nClientType = 0;`
`330`	`331`	`memset(tszSDBuffer, '\0', sizeof(tszSDBuffer));`
`331`	`332`
`332`		`- pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;`
`333`		`-`
`334`	`333`	`SessionModule_Client_GetType(pptszListAddr[i], &nClientType);`
`335`	`334`	`ProtocolModule_Packet_Common(nClientType, pSt_ProtocolHdr, &st_MQProtocol, tszSDBuffer, &nSDLen, lpszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), nMsgLen - sizeof(XENGINE_PROTOCOL_XMQ));`
`336`	`335`	`XEngine_MQXService_Send(pptszListAddr[i], tszSDBuffer, nSDLen, nClientType);`
`@@ -339,8 +338,6 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC`
`339`	`338`	`}`
`340`	`339`	`else`
`341`	`340`	`{`
`342`		`- pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;`
`343`		`-`
`344`	`341`	`if (_tcsxlen(st_MQProtocol.tszMQUsr) > 0)`
`345`	`342`	`{`
`346`	`343`	`//如果发送指定用户被指定.`