server.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
server.go
@@ -53,6 +53,21 @@ } defer ch.Close() ////如果有多个客户端接收,需要改为广播模式 //exErr := ch.ExchangeDeclare( // "alarmExchange", // "fanout", // false, // false, // false, // false, // nil, //) //if exErr != nil { // log.Log.Infof("Failed to declare a exchange,err:", exErr) // return //} q, err := ch.QueueDeclare( "alarm2Android", // name false, // durable