You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/12/28 10:41:38 UTC
[camel] 01/02: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit f5048c2f1301f48669b16bd40f8936210048140f
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Dec 28 11:38:47 2019 +0100
Polished
---
.../main/java/org/apache/camel/zipkin/ZipkinTracer.java | 14 ++------------
1 file changed, 2 insertions(+), 12 deletions(-)
diff --git a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
index 623a97f..4a23044 100644
--- a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
+++ b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
@@ -127,18 +127,8 @@ public class ZipkinTracer extends ServiceSupport implements RoutePolicyFactory,
private static final Logger LOG = LoggerFactory.getLogger(ZipkinTracer.class);
private static final String ZIPKIN_COLLECTOR_HTTP_SERVICE = "zipkin-collector-http";
private static final String ZIPKIN_COLLECTOR_THRIFT_SERVICE = "zipkin-collector-thrift";
- private static final Getter<Message, String> GETTER = new Getter<Message, String>() {
- @Override
- public String get(Message message, String key) {
- return message.getHeader(key, String.class);
- }
- };
- private static final Setter<Message, String> SETTER = new Setter<Message, String>() {
- @Override
- public void put(Message message, String key, String value) {
- message.setHeader(key, value);
- }
- };
+ private static final Getter<Message, String> GETTER = (message, key) -> message.getHeader(key, String.class);
+ private static final Setter<Message, String> SETTER = (message, key, value) -> message.setHeader(key, value);
private static final Extractor<Message> EXTRACTOR = B3Propagation.B3_STRING.extractor(GETTER);
private static final Injector<Message> INJECTOR = B3Propagation.B3_STRING.injector(SETTER);