From 3009eec0d4abe1a69d6aec75e9f5e3c86d847abb Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Mon, 6 Sep 2021 08:56:37 +0200
Subject: [PATCH] Fixed CorrelationId not being imported in Tapeti.Cmd

---
 Tapeti.Cmd/Serialization/SingleFileJSONMessageSerializer.cs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/Tapeti.Cmd/Serialization/SingleFileJSONMessageSerializer.cs b/Tapeti.Cmd/Serialization/SingleFileJSONMessageSerializer.cs
index 2452157..2183c3b 100644
--- a/Tapeti.Cmd/Serialization/SingleFileJSONMessageSerializer.cs
+++ b/Tapeti.Cmd/Serialization/SingleFileJSONMessageSerializer.cs
@@ -241,6 +241,7 @@ namespace Tapeti.Cmd.Serialization
                 if (!string.IsNullOrEmpty(ClusterId)) properties.ClusterId = ClusterId;
                 if (!string.IsNullOrEmpty(ContentEncoding)) properties.ContentEncoding = ContentEncoding;
                 if (!string.IsNullOrEmpty(ContentType)) properties.ContentType = ContentType;
+                if (!string.IsNullOrEmpty(CorrelationId)) properties.CorrelationId = CorrelationId;
                 if (DeliveryMode.HasValue) properties.DeliveryMode = DeliveryMode.Value;
                 if (!string.IsNullOrEmpty(Expiration)) properties.Expiration = Expiration;
                 if (!string.IsNullOrEmpty(MessageId)) properties.MessageId = MessageId;