Decode message that was fanout in the test

ba-st · Sep 3, 2024 · 94a9cbd · 94a9cbd
1 parent 9cd7033
commit 94a9cbd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/source/Ansible-RabbitMQ-Tests/RabbitMQClientTest.class.st b/source/Ansible-RabbitMQ-Tests/RabbitMQClientTest.class.st
@@ -453,14 +453,14 @@ RabbitMQClientTest >> testPublishingToFanoutExchange [
     consumingFrom: 'reverser-queue'
     bindedTo: 'amq.fanout'
     routedBy: routingKey
-    doing: [ :message | firstWorkerMessages add: message reversed ]
+    doing: [ :message | firstWorkerMessages add: message utf8Decoded reversed ]
     during: [
         self
           runWorkerNamed: 'Appender'
           consumingFrom: 'appender-queue'
           bindedTo: 'amq.fanout'
           routedBy: routingKey
-          doing: [ :message | secondWorkerMessages add: message ]
+          doing: [ :message | secondWorkerMessages add: message utf8Decoded ]
           during: [ publisher publish: 'Hello' toExchange: 'amq.fanout' usingRoutingKey: routingKey ]
       ].