1

pool/client.go

@@ -192,6 +192,11 @@ Loop:
 				break Loop
 			}
 
+			if msg.ProcedureType == 9 {
+				pingMsg := &SendMsg{ProcedureType: 10}
+				c.send(pingMsg)
+			}
+
 			SaveMsg(msg)
 			//rabbitMQ.PublishSimple(string(message))
 			c.readMessage(msg)