| | |
| | | var mqPort = flag.Int("mqPort", 5672, "default mq port") |
| | | var mqUser = flag.String("mqUser", "basic", "default rabbitmq user") |
| | | var mqPass = flag.String("mqPass", "basic", "default rabbitmq pass") |
| | | var confPath = flag.String("confPath", "/home/basic/Apps/go/AndroidAlarmServer/config/","default config path") |
| | | |
| | | func main() { |
| | | flag.Parse() |
| | | |
| | | log.SetLogLevel(*Level) |
| | | config.Init(*env) |
| | | config.Init(*env, *confPath) |
| | | fmt.Println(*port) |
| | | //src := *addr + ":" + strconv.Itoa(*port) |
| | | //listener, err := net.Listen("tcp", src) |
| | |
| | | Body: alarmData, |
| | | }) |
| | | if err !=nil { |
| | | log.Log.Infof("send to mq err:",err) |
| | | log.Log.Infof("send to mq err:"+err.Error()) |
| | | } else { |
| | | log.Log.Infof("send to mq success,len(body):",len(alarmData)) |
| | | log.Log.Infof("send to mq success,msg: "+string(alarmData)) |
| | | } |
| | | } |
| | | lastTime = curTime |