diff --git a/business/msghub/msghub.go b/business/msghub/msghub.go index 42835f92a..4f8d68057 100644 --- a/business/msghub/msghub.go +++ b/business/msghub/msghub.go @@ -91,7 +91,7 @@ func registerChan(storeID int, chan2Listen chan<- *ServerMsg) { func unregisterChan(storeID int, chan2Listen chan<- *ServerMsg) { chan2Close := make(chan int) msgChan <- &ServerMsg{ - Type: ServerMsgRegister, + Type: ServerMsgUnregister, MsgData: &MsgOp{ StoreID: storeID, Chan2Listen: chan2Listen,