Skip to content
Snippets Groups Projects
Commit 3cde5ea3 authored by Neil-Jocelyn Schark's avatar Neil-Jocelyn Schark Committed by Neil-Jocelyn Schark
Browse files

wip

parent 8116f3ed
No related branches found
No related tags found
No related merge requests found
...@@ -85,6 +85,8 @@ func connect(addr string) (*amqp.Connection, error) { ...@@ -85,6 +85,8 @@ func connect(addr string) (*amqp.Connection, error) {
// Will equal two Minuten of retries // Will equal two Minuten of retries
retries := 60 retries := 60
logrus.Debugf("will try to connect to: %s", addr)
for i := 0; i < retries; i++ { for i := 0; i < retries; i++ {
conn, err := amqp.Dial(addr) conn, err := amqp.Dial(addr)
if err == nil { if err == nil {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment