From 4d428b8e7d03def4940dd299f09d5f207dd16e64 Mon Sep 17 00:00:00 2001
From: yangduo <yangduo@kingsome.cn>
Date: Fri, 13 Sep 2024 17:28:08 +0800
Subject: [PATCH] fix

---
 server/mqproxy/listener/udplistener.go | 6 +++---
 server/mqproxy/service/mqmgr.go        | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/server/mqproxy/listener/udplistener.go b/server/mqproxy/listener/udplistener.go
index 43191f81..15508200 100644
--- a/server/mqproxy/listener/udplistener.go
+++ b/server/mqproxy/listener/udplistener.go
@@ -68,17 +68,17 @@ func (this *UDPListener) serverRead() {
 							retcode = 0
 						}
 					case "sub":
-						if obj.Topic != "" && obj.Msg != "" {
+						if obj.Topic != "" && obj.Channel != "" {
 							service.MqManager.SubscribeChannel(obj.Topic, obj.Channel)
 							retcode = 0
 						}
 					case "unsub":
-						if obj.Topic != "" && obj.Msg != "" {
+						if obj.Topic != "" && obj.Channel != "" {
 							service.MqManager.UnsubscribeChannel(obj.Topic, obj.Channel)
 							retcode = 0
 						}
 					case "consume":
-						if obj.Topic != "" && obj.Msg != "" {
+						if obj.Topic != "" && obj.Channel != "" {
 							retcode = 0
 							content = service.MqManager.ConsumeTopic(obj.Topic, obj.Channel)
 						}
diff --git a/server/mqproxy/service/mqmgr.go b/server/mqproxy/service/mqmgr.go
index 9060c6f7..31ca600d 100644
--- a/server/mqproxy/service/mqmgr.go
+++ b/server/mqproxy/service/mqmgr.go
@@ -135,7 +135,7 @@ func (this *mqManager) ConsumeTopic(topic, channel string) (msg string) {
 		}
 	}
 
-	if msgidx > 0 {
+	if msgidx > -1 {
 		msg = (*t).msgList[msgidx].content
 		if del {
 			if msgidx+1 < len((*t).msgList) {