package mq

// 单聊
func SingleTalk(tag uint64, ch interface{}, msg []byte) {
	//var data entities.SingTalkReq
	//err := json.Unmarshal(msg, &data)
	//utils.Log(nil, "msg", data)
	//if err == nil {
	//	conn := netool.GetConnManagger().GetConnection(data.Msg.To)
	//	var sendOk = false
	//	if conn != nil && conn.IsActive() {
	//		if utils.WriteMsg(msgid.SINGLE_MSG, data, conn) {
	//			sendOk = true
	//		}
	//	}
	//	if !sendOk {
	//		common.PikaTool.Zadd(utils.GetRealKey(common2.USER_MSG)+data.Msg.To, data, time.Now().Unix())
	//	}
	//}

}