Fixed an issue causing AcceptMessage to hang indefinitely

Working around Azure/go-amqp#126 by batching dispositions SOL-79806
open-telemetry · Oct 14, 2022 · bf61326 · bf61326
1 parent 579d8a6
commit bf61326
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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))