Merge pull request #3537 from Netflix/spotless

Apply spotless
Netflix · Mar 16, 2023 · 8c65ec1 · 8c65ec1
2 parents 17ac903 + a8102db
commit 8c65ec1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -49,10 +49,7 @@ public interface ObservableQueue extends Lifecycle {
     /**
      * @param messages to be Nack'ed
      */
-    default void nack(List<Message> messages)
-    {
-
-    }
+    default void nack(List<Message> messages) {}
 
     /**
      * @param messages Messages to be published