This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-2.20.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit 488bf8bbf50a16a41e3297a8c9206ae622879b0b Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Jun 13 07:40:44 2018 +0200 CAMEL-12573 - Fixed CS --- .../org/apache/camel/opentracing/decorators/KafkaSpanDecorator.java | 4 ++-- .../apache/camel/opentracing/decorators/KafkaSpanDecoratorTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/KafkaSpanDecorator.java b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/KafkaSpanDecorator.java index 1ec0a68..84157c4 100644 --- a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/KafkaSpanDecorator.java +++ b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/KafkaSpanDecorator.java @@ -87,8 +87,8 @@ public class KafkaSpanDecorator extends AbstractMessagingSpanDecorator { * @return */ private <T> String getValue(final Exchange exchange, final String header, Class<T> type) { - T partition = exchange.getIn().getHeader(header, type); - return partition != null ? String.valueOf(partition) : exchange.getIn().getHeader(header, String.class); + T partition = exchange.getIn().getHeader(header, type); + return partition != null ? String.valueOf(partition) : exchange.getIn().getHeader(header, String.class); } } diff --git a/components/camel-opentracing/src/test/java/org/apache/camel/opentracing/decorators/KafkaSpanDecoratorTest.java b/components/camel-opentracing/src/test/java/org/apache/camel/opentracing/decorators/KafkaSpanDecoratorTest.java index 2c51def..0b731b3 100644 --- a/components/camel-opentracing/src/test/java/org/apache/camel/opentracing/decorators/KafkaSpanDecoratorTest.java +++ b/components/camel-opentracing/src/test/java/org/apache/camel/opentracing/decorators/KafkaSpanDecoratorTest.java @@ -92,7 +92,7 @@ public class KafkaSpanDecoratorTest { @Test public void testPrePartitionAsIntegerHeaderAndOffsetAsLongHeader() { - Long testOffset = 4875454l; + Long testOffset = 4875454L; Integer testPartition = 0; Endpoint endpoint = Mockito.mock(Endpoint.class); -- To stop receiving notification emails like this one, please contact acosent...@apache.org.