Skip to content
This repository has been archived by the owner on Dec 13, 2023. It is now read-only.

Commit

Permalink
apply spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
v1r3n committed Mar 16, 2023
1 parent 17ac903 commit a8102db
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit a8102db

Please sign in to comment.