| | |
| | | //var Picurl = flag.String("picurl", "http://58.118.225.79:41242/", "picture url") |
| | | |
| | | var port = flag.Int("port", 6000, "The port to listen on") |
| | | var sec = flag.Int("sec", 10, "the second for query data") |
| | | var sec = flag.Int("sec", 20, "the second for query data") |
| | | |
| | | var Level = flag.String("level","ErrorLevel","log level") |
| | | var IsHub = flag.String("hub", "hub", "hub is personIsHub=1") |
| | |
| | | } |
| | | 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 |