Changeset 38:1d48aca982d8

Fixed checkstyle issues
author unexist
date Thu, 19 Aug 2021 14:36:43 +0200
parents 69db3b1e853d
children 860c4b7ce505
files event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitLifecycle.java event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitRuntimeConfig.java
diffstat 3 files changed, 8 insertions(+), 7 deletions(-) [+]
line wrap: on
line diff
--- a/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java	Thu Aug 19 14:04:04 2021 +0200
+++ b/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java	Thu Aug 19 14:36:43 2021 +0200
@@ -8,7 +8,7 @@
  * This program can be distributed under the terms of the Apache License v2.0.
  * See the file LICENSE for details.
  **/
- 
+
 package dev.unexist.showcase.eventsplit;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -34,9 +34,7 @@
 @ApplicationScoped
 public class EventSplitDispatcher {
     private static final Logger LOGGER = LoggerFactory.getLogger(EventSplitDispatcher.class);
-    private final static ObjectMapper MAPPER = new ObjectMapper();
-
-    private KafkaConsumer<String, String> consumer;
+    private static final ObjectMapper MAPPER = new ObjectMapper();
 
     @Inject
     EventSplitRuntimeConfig runtimeConfig;
@@ -44,6 +42,8 @@
     @Inject
     EventBus bus;
 
+    private KafkaConsumer<String, String> consumer;
+
     /**
      * Start the dispatcher
      **/
@@ -71,7 +71,7 @@
         if (null != this.runtimeConfig.topics) {
             this.consumer.subscribe(new HashSet<>(Arrays.asList(this.runtimeConfig.topics.split(","))));
 
-            LOGGER.info("Subscribed to topics: " + this.runtimeConfig.topics);
+            LOGGER.info("Subscribed to topics: {}", this.runtimeConfig.topics);
         }
 
         /* Set up handler */
--- a/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitLifecycle.java	Thu Aug 19 14:04:04 2021 +0200
+++ b/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitLifecycle.java	Thu Aug 19 14:36:43 2021 +0200
@@ -8,7 +8,7 @@
  * This program can be distributed under the terms of the Apache License v2.0.
  * See the file LICENSE for details.
  **/
- 
+
 package dev.unexist.showcase.eventsplit;
 
 import io.quarkus.runtime.StartupEvent;
--- a/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitRuntimeConfig.java	Thu Aug 19 14:04:04 2021 +0200
+++ b/event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitRuntimeConfig.java	Thu Aug 19 14:36:43 2021 +0200
@@ -8,7 +8,7 @@
  * This program can be distributed under the terms of the Apache License v2.0.
  * See the file LICENSE for details.
  **/
- 
+
 package dev.unexist.showcase.eventsplit;
 
 import io.quarkus.runtime.annotations.ConfigItem;
@@ -16,6 +16,7 @@
 import io.quarkus.runtime.annotations.ConfigRoot;
 
 @ConfigRoot(phase = ConfigPhase.RUN_TIME, name = "event-split")
+@SuppressWarnings("VisibilityModifier")
 public class EventSplitRuntimeConfig {
 
     /**