From a8102dbe2eb30a8f4b00da3749c63909d20e06d5 Mon Sep 17 00:00:00 2001 From: Viren Baraiya Date: Wed, 15 Mar 2023 23:08:55 -0700 Subject: [PATCH] apply spotless --- .../netflix/conductor/core/events/DefaultEventProcessor.java | 3 +-- .../netflix/conductor/core/events/queue/ObservableQueue.java | 5 +---- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/core/src/main/java/com/netflix/conductor/core/events/DefaultEventProcessor.java b/core/src/main/java/com/netflix/conductor/core/events/DefaultEventProcessor.java index 256e8abaf1..520c585b42 100644 --- a/core/src/main/java/com/netflix/conductor/core/events/DefaultEventProcessor.java +++ b/core/src/main/java/com/netflix/conductor/core/events/DefaultEventProcessor.java @@ -133,8 +133,7 @@ public void handle(ObservableQueue queue, Message msg) { // from the queue queue.publish(Collections.singletonList(msg)); LOGGER.debug("Message: {} published to queue: {}", msg.getId(), queue.getName()); - } - else { + } else { queue.nack(Collections.singletonList(msg)); LOGGER.debug("Message: {} nacked on queue: {}", msg.getId(), queue.getName()); } diff --git a/core/src/main/java/com/netflix/conductor/core/events/queue/ObservableQueue.java b/core/src/main/java/com/netflix/conductor/core/events/queue/ObservableQueue.java index b7b7572f1b..ecdc759216 100644 --- a/core/src/main/java/com/netflix/conductor/core/events/queue/ObservableQueue.java +++ b/core/src/main/java/com/netflix/conductor/core/events/queue/ObservableQueue.java @@ -49,10 +49,7 @@ public interface ObservableQueue extends Lifecycle { /** * @param messages to be Nack'ed */ - default void nack(List messages) - { - - } + default void nack(List messages) {} /** * @param messages Messages to be published