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))