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<Message> messages)
-    {
-
-    }
+    default void nack(List<Message> messages) {}
 
     /**
      * @param messages Messages to be published