fixed:does not set timepublish value when the value = 0

Author: xengine-qyt

XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp

@@ -454,6 +454,7 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 					BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_ListUser, nListCount);
 					XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("%s消息端:%s,主题:%s,序列:%lld,投递数据到消息队列成功,通知客户端个数:%d"), lpszClientType, lpszClientAddr, st_DBQueue.tszQueueName, st_DBQueue.nQueueSerial, nListCount);
 				}
+				_xstprintf(st_DBQueue.tszQueuePublishTime, _X("0"));
 			}
 			else
 			{

XEngine_Source/XQueue_ProtocolHdr.h

@@ -37,7 +37,6 @@
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPTOPICUNBIND 0x7019    //回复
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQMSGMODIFY 0x7020      //消息修改请求
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPMSGMODIFY 0x7021      //消息修改回复
-
 //用户协议
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQUSERLOG 0x7020        //用户登录
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPUSERLOG 0x7021        
@@ -68,10 +67,10 @@ typedef struct
 //消息队列服务协议
 typedef struct 
 {
-	XCHAR tszMQKey[256];                                                  //此消息的KEY，不能为空
+	XCHAR tszMQKey[MAX_PATH];                                             //此消息的KEY，不能为空
 	__int64x nSerial;                                                     //包序列号
 	__int64x nPubTime;                                                    //发布时间，根据自己需求配置时区
-	int nKeepTime;                                                        //保持时间,单位秒,-1 永久存在 0 一次就结束,>0 保存秒数
+	int nKeepTime;                                                        //可用时间,单位秒,>0 超时秒数
 	XENGINE_PROTOCOL_MSGATTR st_MSGAttr;                                  //消息属性
 }XENGINE_PROTOCOL_XMQ, * LPXENGINE_PROTOCOL_XMQ;
 typedef struct