|
@@ -95,19 +95,6 @@ func (c *Line) getPingID() uint16 {
|
|
return c.pingID
|
|
return c.pingID
|
|
}
|
|
}
|
|
|
|
|
|
-// 设置频道名
|
|
|
|
-func (c *Line) SetChannelName(name string) {
|
|
|
|
- if strings.Contains(name, "@") {
|
|
|
|
- c.channel = name
|
|
|
|
- } else {
|
|
|
|
- if inx := strings.Index(c.channel, "@"); inx >= 0 {
|
|
|
|
- c.channel = name + c.channel[inx:]
|
|
|
|
- } else {
|
|
|
|
- c.channel = name + "@" + c.channel
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
// 读信息循环通道,采用新线程
|
|
// 读信息循环通道,采用新线程
|
|
func (c *Line) readPump() {
|
|
func (c *Line) readPump() {
|
|
for {
|
|
for {
|