fixed preserving case sensitivity of external headers

eclipse-ditto · Jan 21, 2025 · 1fb100a · 1fb100a
1 parent 169d4a0
commit 1fb100a
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git a/...ce/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BasePublisherActor.java b/...ce/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BasePublisherActor.java
@@ -486,6 +486,7 @@ private SendingOrDropped publishToGenericTarget(final ExpressionResolver resolve
                             DittoHeaders.newBuilder(mappedMessage.getHeaders())
                                     .removeHeader(DittoHeaderDefinition.W3C_TRACEPARENT.getKey())
                                     .build()
+                                    .asCaseSensitiveMap()
                     ));
 
             final CompletionStage<SendResult> responsesFuture = publishMessage(outboundSource,

diff --git a/...rc/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java b/...rc/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java
@@ -367,6 +367,7 @@ private void handleJmsMessage(final JmsMessage message) throws JMSException {
                     .toBuilder()
                     .removeHeader(DittoHeaderDefinition.W3C_TRACEPARENT.getKey())
                     .build()
+                    .asCaseSensitiveMap()
             );
             final ExternalMessageBuilder builder = ExternalMessageFactory.newExternalMessageBuilder(headers);
             final ExternalMessage externalMessage = extractPayloadFromMessage(message, builder)

diff --git a/.../java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java b/.../java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaMessageTransformer.java
@@ -116,6 +116,7 @@ public TransformationResult transform(final ConsumerRecord<String, ByteBuffer> c
                 .toBuilder()
                 .removeHeader(DittoHeaderDefinition.W3C_TRACEPARENT.getKey())
                 .build()
+                .asCaseSensitiveMap()
         );
 
         try {

diff --git a/...java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQConsumerActor.java b/...java/org/eclipse/ditto/connectivity/service/messaging/rabbitmq/RabbitMQConsumerActor.java
@@ -155,6 +155,7 @@ private void handleDelivery(final Delivery delivery) {
                     .toBuilder()
                     .removeHeader(DittoHeaderDefinition.W3C_TRACEPARENT.getKey())
                     .build()
+                    .asCaseSensitiveMap()
             );
 
             final ExternalMessageBuilder externalMessageBuilder =