From ccb7e128c2f5dc76ac9ef3124f442deab936c389 Mon Sep 17 00:00:00 2001 From: Gustavo Martin Morcuende Date: Sun, 29 Jan 2017 11:28:18 +0100 Subject: [PATCH] Improving code --- SpringJava/Kafka/SpringCloudStream/README | 2 +- .../src/main/java/de/example/spring/kafka/MyCustomMessageConverter.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/SpringJava/Kafka/SpringCloudStream/README b/SpringJava/Kafka/SpringCloudStream/README index f5f6539..876ab4b 100644 --- a/SpringJava/Kafka/SpringCloudStream/README +++ b/SpringJava/Kafka/SpringCloudStream/README @@ -12,7 +12,7 @@ Debugging from Eclipse/IntelliJ does not work because it needs to search for resources in /BOOT-INF/lib and /BOOT-INF/classes directories. By default Eclipse/IntelliJ do not know anything about those folders :( -spring-boot-maven-plugin creates META-INF/MANIFEST.MF in target/my.jar file whe this value: +spring-boot-maven-plugin creates META-INF/MANIFEST.MF in target/my.jar file whith this value: Main-Class: org.springframework.boot.loader.JarLauncher JarLauncher contains: https://github.com/spring-projects/spring-boot/blob/master/spring-boot-tools/spring-boot-loader/src/main/java/org/springframework/boot/loader/JarLauncher.java diff --git a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/MyCustomMessageConverter.java b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/MyCustomMessageConverter.java index 13667ad..cc56794 100644 --- a/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/MyCustomMessageConverter.java +++ b/SpringJava/Kafka/SpringCloudStream/spring-cloud-stream-kafka-consumer-example/src/main/java/de/example/spring/kafka/MyCustomMessageConverter.java @@ -21,6 +21,6 @@ public class MyCustomMessageConverter extends AbstractMessageConverter { logger.info("convertFromInternal, payload: " + payload); - return (payload instanceof String ? payload : new String((byte[]) payload)); + return payload instanceof String ? payload : new String((byte[]) payload); } } -- 2.1.4