(msgID uint32, data []byte, opts ...ziface.MsgSendOption)
| 466 | } |
| 467 | |
| 468 | func (c *Connection) SendBuffMsg(msgID uint32, data []byte, opts ...ziface.MsgSendOption) error { |
| 469 | msg, err := c.packet.Pack(zpack.NewMsgPackage(msgID, data)) |
| 470 | if err != nil { |
| 471 | zlog.Ins().ErrorF("Pack error msg ID = %d", msgID) |
| 472 | return errors.New("Pack error msg ") |
| 473 | } |
| 474 | return c.SendToQueue(msg, opts...) |
| 475 | |
| 476 | } |
| 477 | |
| 478 | func (c *Connection) SetProperty(key string, value interface{}) { |
| 479 | c.propertyLock.Lock() |
nothing calls this directly
no test coverage detected