From 5cd136c5587a310d453bcb2810695687a41d4be0 Mon Sep 17 00:00:00 2001 From: Sonja Happ Date: Mon, 3 Jan 2022 12:38:29 +0100 Subject: [PATCH] amqp: queue bugfix --- helper/amqp_session.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/helper/amqp_session.go b/helper/amqp_session.go index b6aa1c8..209d422 100644 --- a/helper/amqp_session.go +++ b/helper/amqp_session.go @@ -150,7 +150,7 @@ func (session *AMQPsession) init(conn *amqp.Connection) error { } // add a queue for the ICs - ICQueue, err := sendCh.QueueDeclare("", + sendQueue, err := sendCh.QueueDeclare("", false, 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) } - err = sendCh.QueueBind(ICQueue.Name, "", session.exchange, false, nil) + err = sendCh.QueueBind(sendQueue.Name, "", session.exchange, false, nil) if err != nil { 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) // start deliveries - messages, err := session.recvCh.Consume(ICQueue.Name, + messages, err := session.recvCh.Consume(sendQueue.Name, "", true, false,