sleep fix
This commit is contained in:
parent
9736a2ebaf
commit
4fe2eb5b37
2
mq.go
2
mq.go
@ -140,7 +140,7 @@ func MQKeepAliveWorker() {
|
|||||||
logOnError(err, "MQKeepAliveWorker : Publishing message.")
|
logOnError(err, "MQKeepAliveWorker : Publishing message.")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
t.Sleep(time.Minute)
|
time.Sleep(time.Minute)
|
||||||
}
|
}
|
||||||
log.Printf("MQKeepAliveWorker : Closing.")
|
log.Printf("MQKeepAliveWorker : Closing.")
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user