alihan/fn-serverless
1
0
Fork 0
mirror of https://github.com/fnproject/fn.git synced 2022-10-28 21:29:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

Place srv.Run() last in the start up process

Browse Source 
Smaller and simpler code, runner.RunAsyncRunner
This commit is contained in:
Carlos C
2016-10-03 21:27:57 +02:00
parent 5b36ed0833
commit 39a582e2dd
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
main.go
View File

@@ -46,9 +46,6 @@ func main() {
log.WithError(err).Fatalln("Failed to create a runner") log.WithError(err).Fatalln("Failed to create a runner")
} }
srv := server.New(ds, mqType, rnr)
go srv.Run(ctx)
nasync := 1 nasync := 1
if nasyncStr := strings.TrimSpace(viper.GetString("NASYNC")); len(nasyncStr) > 0 { if nasyncStr := strings.TrimSpace(viper.GetString("NASYNC")); len(nasyncStr) > 0 {
var err error var err error
@@ -62,7 +59,6 @@ func main() {
go runner.RunAsyncRunner(mqAdr) go runner.RunAsyncRunner(mqAdr)
} }
quit := make(chan bool) srv := server.New(ds, mqType, rnr)
for _ = range quit { srv.Run(ctx)
}
} }