Skip to content
Snippets Groups Projects
Commit 149199ba authored by Fabian Seidl's avatar Fabian Seidl
Browse files

fix description

parent 4aa8252e
No related branches found
No related tags found
1 merge request!1217Fix multiple rabbitmq consumers receiving all messages
Pipeline #262446 passed
This commit is part of merge request !1217. Comments created here will be created in the context of that merge request.
...@@ -110,7 +110,7 @@ func (e *Service) setupQueueConsume(topic string, stopChan chan os.Signal) error ...@@ -110,7 +110,7 @@ func (e *Service) setupQueueConsume(topic string, stopChan chan os.Signal) error
nil, nil,
) )
if err != nil { if err != nil {
return &customerrs.AMQPInitFailError{Action: "failed binding to queue to exchange", Err: err} return &customerrs.AMQPInitFailError{Action: "failed binding queue to exchange", Err: err}
} }
msgs, err := e.channel.Consume( msgs, err := e.channel.Consume(
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment