Set Pubsub message attribute "batched" with value

JasperFx · Dec 4, 2024 · e05173e · e05173e
1 parent 1bc8b0e
commit e05173e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)