Skip to content
Snippets Groups Projects

Fix multiple rabbitmq consumers receiving all messages

Merged Fabian Seidl requested to merge fix-for-multiple-rabbitmq-consumers into master
2 files
+ 8
5
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -87,7 +87,7 @@ func (e *Service) setupQueueConsume(topic string, stopChan chan os.Signal) error
nil, // arguments
)
if err != nil {
return &customerrs.AMQPMessageFailError{Action: "failed declaring queue", Err: err}
return &customerrs.AMQPInitFailError{Action: "failed declaring exchange", Err: err}
}
q, err := e.channel.QueueDeclare(
@@ -99,7 +99,7 @@ func (e *Service) setupQueueConsume(topic string, stopChan chan os.Signal) error
nil, // arguments
)
if err != nil {
return &customerrs.AMQPMessageFailError{Action: "failed declaring queue", Err: err}
return &customerrs.AMQPInitFailError{Action: "failed declaring queue", Err: err}
}
err = e.channel.QueueBind(
@@ -110,7 +110,7 @@ func (e *Service) setupQueueConsume(topic string, stopChan chan os.Signal) error
nil,
)
if err != nil {
return &customerrs.AMQPMessageFailError{Action: "failed declaring queue", Err: err}
return &customerrs.AMQPInitFailError{Action: "failed binding to queue to exchange", Err: err}
}
msgs, err := e.channel.Consume(
Loading