go fmt updates
This commit is contained in:
parent
93ccd37c82
commit
ab538ec332
|
@ -42,7 +42,7 @@ func main() {
|
|||
|
||||
ras, err := rpc.NewRegistrationAuthorityServer(c.AMQP.RA.Server, ch, &rai)
|
||||
cmd.FailOnError(err, "Unable to create RA server")
|
||||
|
||||
|
||||
cmd.RunUntilSignaled(auditlogger, ras, closeChan)
|
||||
}
|
||||
|
||||
|
|
|
@ -50,7 +50,7 @@ func main() {
|
|||
for {
|
||||
for err := range closeChan {
|
||||
auditlogger.Warning(fmt.Sprintf("AMQP Channel closed, will reconnect in 5 seconds: [%s]", err))
|
||||
time.Sleep(time.Second*5)
|
||||
time.Sleep(time.Second * 5)
|
||||
rac, sac, closeChan = setupWFE(c, auditlogger)
|
||||
wfe.RA = &rac
|
||||
wfe.SA = &sac
|
||||
|
|
|
@ -150,9 +150,9 @@ func RunUntilSignaled(logger *blog.AuditLogger, server *rpc.AmqpRPCServer, close
|
|||
fmt.Fprintf(os.Stderr, "Server running...\n")
|
||||
|
||||
// Block until channel closes
|
||||
err := <- closeChan
|
||||
err := <-closeChan
|
||||
|
||||
logger.Warning(fmt.Sprintf("AMQP Channel closed, will reconnect in 5 seconds: [%s]", err))
|
||||
time.Sleep(time.Second*5)
|
||||
time.Sleep(time.Second * 5)
|
||||
logger.Warning("Reconnecting to AMQP...")
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue