Merge pull request #119 from SwissDataScienceCenter/payload-decoding

Use content-type from header when decoding payload
SwissDataScienceCenter · May 14, 2024 · 877f4f0 · 877f4f0
2 parents 2054926 + f5ba49d
commit 877f4f0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/modules/events/src/main/scala/io/renku/search/events/MessageHeader.scala b/modules/events/src/main/scala/io/renku/search/events/MessageHeader.scala
@@ -81,10 +81,10 @@ object MessageHeader:
   ): DataContentType =
     if (headerCt != decoded) {
       scribe.warn(
-        s"ContentType ($headerCt) used for decoding the header is not same as advertised in the header ($decoded)! Choose the one used for decoding the header to continue ($headerCt)."
+        s"ContentType ($headerCt) used for decoding the header is not same as advertised in the header ($decoded)! Choose the advertised format in the header to continue ($decoded)."
       )
     }
-    headerCt
+    decoded
 
   def fromByteVector(bv: ByteVector): Either[DecodeFailure, MessageHeader] =
     readBinaryOrJson(bv)