main.go 587 B

12345678910111213141516171819202122232425262728293031
  1. package main
  2. import (
  3. "flag"
  4. "sparrow/pkg/rpcs"
  5. "sparrow/pkg/server"
  6. "sparrow/services/timer-service/internal"
  7. )
  8. const (
  9. flagRabbitHost = "rabbithost"
  10. defaultRabbitHost = "amqp://guest:guest@localhost:5672/"
  11. )
  12. var (
  13. confRabbitHost = flag.String(flagRabbitHost, defaultRabbitHost, "rabbitmq host address, amqp://user:password@ip:port/")
  14. )
  15. func main() {
  16. // init server
  17. err := server.Init(rpcs.TimerServiceName)
  18. if err != nil {
  19. server.Log.Fatal(err)
  20. return
  21. }
  22. internal.NewTimerService(*confRabbitHost)
  23. err = server.Run()
  24. if err != nil {
  25. server.Log.Fatal(err)
  26. }
  27. }