[camel] branch camel-2.25.x updated: Convert []byte header to string (#3994)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch camel-2.25.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.25.x by this push:
     new 6de1fe0  Convert []byte header to string (#3994)
6de1fe0 is described below

commit 6de1fe0e8f04118bf5bc8dcc7759849b67a36b40
Author: Ruben Vargas Palma <ruben.vp8...@gmail.com>
AuthorDate: Mon Jul 13 04:54:16 2020 -0500

    Convert []byte header to string (#3994)
    
    Signed-off-by: Ruben <ruben.vp8...@gmail.com>
---
 .../propagation/CamelMessagingHeadersExtractAdapter.java         | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/propagation/CamelMessagingHeadersExtractAdapter.java
 
b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/propagation/CamelMessagingHeadersExtractAdapter.java
index 3a2b467..ea45a46 100644
--- 
a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/propagation/CamelMessagingHeadersExtractAdapter.java
+++ 
b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/propagation/CamelMessagingHeadersExtractAdapter.java
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.opentracing.propagation;
 
+import java.nio.charset.StandardCharsets;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.Map;
@@ -30,7 +31,13 @@ public final class CamelMessagingHeadersExtractAdapter 
implements TextMap {
     public CamelMessagingHeadersExtractAdapter(final Map<String, Object> map, 
boolean jmsEncoding) {
         // Extract string valued map entries
         this.jmsEncoding = jmsEncoding;
-        map.entrySet().stream().filter(e -> e.getValue() instanceof 
String).forEach(e -> this.map.put(decodeDash(e.getKey()), 
(String)e.getValue()));
+        map.entrySet().stream().filter(e -> e.getValue() instanceof String || 
e.getValue() instanceof byte[]).forEach(e -> {
+            if (e.getValue() instanceof byte[]) {
+                this.map.put(decodeDash(e.getKey()), new 
String((byte[])e.getValue(), StandardCharsets.UTF_8));
+            } else {
+                this.map.put(decodeDash(e.getKey()), (String)e.getValue());
+            }
+        });
     }
 
     @Override