Publish plain TypedData instead of using EncodeBinaryModeEventData. (#…

…286)
GDATASoftwareAG · Aug 9, 2021 · 900a3d5 · 900a3d5
1 parent e740c84
commit 900a3d5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/shared.csproj b/shared.csproj
@@ -1,7 +1,7 @@
 <Project>
 
     <PropertyGroup>
-        <Version>0.7.3</Version>
+        <Version>0.7.4</Version>
         <LangVersion>9</LangVersion>
         <Nullable>enable</Nullable>
         <WarningsAsErrors>CS8600;CS8602;CS8625;CS8618;CS8604;CS8601</WarningsAsErrors>

diff --git a/src/Motor.Extensions.Hosting.RabbitMQ/RabbitMQMessagePublisher.cs b/src/Motor.Extensions.Hosting.RabbitMQ/RabbitMQMessagePublisher.cs
@@ -55,8 +55,7 @@ public async Task PublishMessageAsync(MotorCloudEvent<byte[]> motorCloudEvent, C
                 exchange = _options.PublishingTarget.Exchange;
             }
 
-            _channel.BasicPublish(exchange, routingKey, true, properties,
-                _cloudEventFormatter.EncodeBinaryModeEventData(motorCloudEvent.ConvertToCloudEvent()));
+            _channel.BasicPublish(exchange, routingKey, true, properties, motorCloudEvent.TypedData);
         }
 
         private Task StartAsync()