# HG changeset patch # User unexist # Date 1629376603 -7200 # Node ID 1d48aca982d8d14172bed1d8aa08dbd50550fadf # Parent 69db3b1e853d1fb6ea3bf2cbcdf056076ff147de Fixed checkstyle issues diff -r 69db3b1e853d -r 1d48aca982d8 event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitDispatcher.java --- 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 consumer; + private static final ObjectMapper MAPPER = new ObjectMapper(); @Inject EventSplitRuntimeConfig runtimeConfig; @@ -44,6 +42,8 @@ @Inject EventBus bus; + private KafkaConsumer 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 */ diff -r 69db3b1e853d -r 1d48aca982d8 event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitLifecycle.java --- 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; diff -r 69db3b1e853d -r 1d48aca982d8 event-split-extension-parent/runtime/src/main/java/dev/unexist/showcase/eventsplit/EventSplitRuntimeConfig.java --- 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 { /**