1

server/imserver/WSPListener.go

@@ -13,7 +13,7 @@ import (
 
 type WSPListener_ struct {
 	listener net.Listener
-	ch <-chan *q5.MsgHdr
+	ch chan *q5.MsgHdr
 	msgList q5.ListHead
 }
 
@@ -119,6 +119,7 @@ func (this *WSPListener_) decodePacket(buf []byte, offset *int, bufLen int) {
 			hdr := new(q5.MsgHdr)
 			hdr.MsgId = int(buf[*offset + 2]) + int(buf[*offset + 3] << 16)
 			//hdr.SeqId = int(recvBuf[4]) + int(recvBuf[5] )
+			this.ch <- hdr
 			*offset += 20 + packLen
 		} else {
 			warning = true