Skip to content

Commit f64f930

Browse files
committed
Add minimal sleep for links to be established
1 parent 49941bd commit f64f930

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

rabbitmq_amqp/amqp_management.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,11 @@ func (a *AmqpManagement) Open(ctx context.Context, connection IConnection) error
100100
return err
101101
}
102102

103-
time.Sleep(time.Second)
103+
// TODO
104+
// Even 10ms is enough to allow the links to establish,
105+
// which tells me it allows the golang runtime to process
106+
// some channels elsewhere
107+
time.Sleep(time.Millisecond * 10)
104108

105109
a.lifeCycle.SetStatus(Open)
106110
return ctx.Err()

0 commit comments

Comments
 (0)