Mirrors/VILLASweb-backend-go
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/web-backend-go/ synced 2025-03-30 00:00:12 +01:00
Code Issues Releases Wiki Activity

amqp: queue bugfix

Browse source
This commit is contained in:
Sonja Happ 2022-01-03 12:38:29 +01:00
parent 07c99d13c8
commit 5cd136c558
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
helper/amqp_session.go
View file

@ -150,7 +150,7 @@ func (session *AMQPsession) init(conn *amqp.Connection) error {
} }
// add a queue for the ICs // add a queue for the ICs
ICQueue, err := sendCh.QueueDeclare("", sendQueue, err := sendCh.QueueDeclare("",
false, false,
true, true,
true, true,
@ -160,7 +160,7 @@ func (session *AMQPsession) init(conn *amqp.Connection) error {
return fmt.Errorf("AMQP: failed to declare the queue, error: %v", err) return fmt.Errorf("AMQP: failed to declare the queue, error: %v", err)
} }
err = sendCh.QueueBind(ICQueue.Name, "", session.exchange, false, nil) err = sendCh.QueueBind(sendQueue.Name, "", session.exchange, false, nil)
if err != nil { if err != nil {
return fmt.Errorf("AMQP: failed to bind the queue, error: %v", err) return fmt.Errorf("AMQP: failed to bind the queue, error: %v", err)
} }
@ -184,7 +184,7 @@ func (session *AMQPsession) init(conn *amqp.Connection) error {
session.recvCh.NotifyPublish(session.notifyRecvConfirm) session.recvCh.NotifyPublish(session.notifyRecvConfirm)
// start deliveries // start deliveries
messages, err := session.recvCh.Consume(ICQueue.Name, messages, err := session.recvCh.Consume(sendQueue.Name,
"", "",
true, true,
false, false,