Merge pull request #42 from symsimmy/fix/onTraffic

fix onTraffic
symsimmy · Oct 21, 2024 · 923b4f6 · 923b4f6
2 parents f1bad0e + 508f01b
commit 923b4f6
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/transport/gnet/tcp/server.go b/transport/gnet/tcp/server.go
@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"github.com/golang/protobuf/proto"
 	"github.com/panjf2000/gnet/v2"
-	"github.com/symsimmy/due/errors"
 	"github.com/symsimmy/due/common/endpoint"
+	"github.com/symsimmy/due/errors"
 	"github.com/symsimmy/due/log"
 	"github.com/symsimmy/due/transport"
 )
@@ -70,9 +70,7 @@ func (s *Server) OnTraffic(c gnet.Conn) (action gnet.Action) {
 		v, err := s.receiveHandler(data.Route, data.Data)
 
 		if err != nil {
-			log.Debugf("server receive messageId:[%+v],handler[route=%+v] failed.err:%+v", data.Route, data.MessageId, err)
-
-			continue
+			log.Errorf("server receive messageId:[%+v],handler[route=%+v] failed.err:%+v", data.Route, data.MessageId, err)
 		}
 
 		if v != nil {