From bf613269715f3ceda0c67ee22a27221618986a32 Mon Sep 17 00:00:00 2001 From: Michael Cardy Date: Fri, 14 Oct 2022 11:25:14 -0400 Subject: [PATCH] Fixed an issue causing AcceptMessage to hang indefinitely Working around Azure/go-amqp#126 by batching dispositions SOL-79806 --- receiver/solacereceiver/messaging_service.go | 1 + 1 file changed, 1 insertion(+) diff --git a/receiver/solacereceiver/messaging_service.go b/receiver/solacereceiver/messaging_service.go index 29f7de49730d..d95fed705f5c 100644 --- a/receiver/solacereceiver/messaging_service.go +++ b/receiver/solacereceiver/messaging_service.go @@ -139,6 +139,7 @@ func (m *amqpMessagingService) dial() (err error) { amqp.LinkSourceAddress(m.receiverConfig.queue), amqp.LinkCredit(m.receiverConfig.maxUnacked), amqp.LinkName(telemetryLinkName), + amqp.LinkBatching(true), ) if err != nil { m.logger.Debug("Create AMQP Receiver Link failure", zap.Error(err))