From e0fe5873f1ae0fe6f5cc38f0af2459f4f4ef832f Mon Sep 17 00:00:00 2001 From: jay-zahiri <11631617+jay-zahiri@users.noreply.github.com> Date: Wed, 4 Dec 2024 21:15:14 +0100 Subject: [PATCH] Set Pubsub message attribute "batched" with value --- .../GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs b/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs index caddd7df..f63ec2ba 100644 --- a/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs +++ b/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs @@ -47,7 +47,7 @@ public void MapOutgoingToMessage(OutgoingMessageBatch outgoing, PubsubMessage me { message.Data = ByteString.CopyFrom(outgoing.Data); message.Attributes["destination"] = outgoing.Destination.ToString(); - message.Attributes["batched"] = string.Empty; + message.Attributes["batched"] = "1"; } protected override void writeOutgoingHeader(PubsubMessage outgoing, string key, string value)