enforce code formating for new classes

Author: ggivo

pom.xml

@@ -348,6 +348,11 @@
 						<include>src/test/java/redis/clients/jedis/commands/jedis/ClusterStreamsCommandsTest.java</include>
 						<include>src/test/java/redis/clients/jedis/commands/jedis/PooledStreamsCommandsTest.java</include>
 						<include>src/test/java/redis/clients/jedis/resps/StreamEntryDeletionResultTest.java</include>
+						<include>**/Maintenance*.java</include>
+						<include>**/Push*.java</include>
+						<include>**/Rebind*.java</include>
+						<include>src/test/java/redis/clients/jedis/upgrade/*.java</include>
+						<include>src/test/java/redis/clients/jedis/util/server/*.java</include>
 					</includes>
 				</configuration>
 				<executions>

src/main/java/redis/clients/jedis/MaintenanceEventHandler.java

@@ -4,12 +4,9 @@
 
 public interface MaintenanceEventHandler {
 
-
   void addListener(MaintenanceEventListener listener);
 
-
   void removeListener(MaintenanceEventListener listener);
 
-
   Collection<MaintenanceEventListener> getListeners();
 }

src/main/java/redis/clients/jedis/MaintenanceEventListener.java

@@ -1,15 +1,19 @@
 package redis.clients.jedis;
 
-
 public interface MaintenanceEventListener {
 
-  default void onMigrating(){};
+  default void onMigrating() {
+  };
 
-  default void onMigrated(){};
+  default void onMigrated() {
+  };
 
-  default void onFailOver(){};
+  default void onFailOver() {
+  };
 
-  default void onFailedOver(){};
+  default void onFailedOver() {
+  };
 
-  default void onRebind( HostAndPort target){};
+  default void onRebind(HostAndPort target) {
+  };
 }

src/main/java/redis/clients/jedis/PushConsumer.java

@@ -8,10 +8,10 @@ public interface PushConsumer {
 
   /**
    * Handle a push message.
-   *
-   * Messages are not processed by default.  Handlers should update the context's processed flag to true if they
-   * have processed the message.
-   *
+   * <p>
+   * Messages are not processed by default. Handlers should update the
+   * context's processed flag to true if they have processed the message.
+   * </p>
    * @param context The context of the message to respond to.
    */
   void accept(PushConsumerContext context);

src/main/java/redis/clients/jedis/PushConsumerChain.java

@@ -12,7 +12,9 @@
 
 /**
  * A chain of PushHandlers that processes events in order.
+ * <p>
  * Uses a context object for tracking the processed state.
+ * </p>
  */
 @Internal
 public final class PushConsumerChain implements PushConsumer {
@@ -37,13 +39,14 @@ public final class PushConsumerChain implements PushConsumer {
     context.setProcessed(false);
   };
 
-
   /**
-   * Handler that allows only pub/sub related events to be propagated to the client.
+   * Handler that allows only pub/sub related events to be propagated to the client
+   * <p>
    * Marks non-pub/sub events as processed, preventing their propagation.
+   * </p>
    */
-  public static final PushConsumer PUBSUB_ONLY_HANDLER = new PushConsumer(){
-    final Set<String> pubSubCommands =  new HashSet<>();
+  public static final PushConsumer PUBSUB_ONLY_HANDLER = new PushConsumer() {
+    final Set<String> pubSubCommands = new HashSet<>();
     {
       pubSubCommands.add("message");
       pubSubCommands.add("pmessage");
@@ -69,7 +72,6 @@ private boolean isPubSubType(String type) {
     }
   };
 
-
   /**
    * Create a new empty handler chain.
    */
@@ -79,7 +81,6 @@ public PushConsumerChain() {
 
   /**
    * Create a chain with the specified handlers.
-   *
    * @param consumers The handlers to add to the chain
    */
   public PushConsumerChain(PushConsumer... consumers) {
@@ -88,7 +89,6 @@ public PushConsumerChain(PushConsumer... consumers) {
 
   /**
    * Create a chain with a single handler.
-   *
    * @param handler The handler to include in the chain
    * @return A new handler chain with the specified handler
    */
@@ -98,7 +98,6 @@ public static PushConsumerChain of(PushConsumer handler) {
 
   /**
    * Create a chain with the specified handlers.
-   *
    * @param handlers The handlers to add to the chain
    * @return A new handler chain with the specified handlers
    */
@@ -108,7 +107,6 @@ public static PushConsumerChain of(PushConsumer... handlers) {
 
   /**
    * Add a handler to be executed after this chain.
-   *
    * @param handler The handler to add
    * @return A new chain with the handler added
    */
@@ -126,7 +124,6 @@ public PushConsumerChain then(PushConsumer handler) {
 
   /**
    * Add a handler to the end of the chain.
-   *
    * @param handler The handler to add
    * @return this chain for method chaining
    */
@@ -139,7 +136,6 @@ public PushConsumerChain add(PushConsumer handler) {
 
   /**
    * Insert a handler at the specified position.
-   *
    * @param index The position to insert at (0-based)
    * @param handler The handler to insert
    * @return this chain for method chaining
@@ -153,7 +149,6 @@ public PushConsumerChain insert(int index, PushConsumer handler) {
 
   /**
    * Remove a handler from the chain.
-   *
    * @param handler The handler to remove
    * @return true if the handler was removed
    */
@@ -163,7 +158,6 @@ public boolean remove(PushConsumer handler) {
 
   /**
    * Remove the handler at the specified position.
-   *
    * @param index The position to remove from (0-based)
    * @return The removed handler
    */
@@ -173,7 +167,6 @@ public PushConsumer removeAt(int index) {
 
   /**
    * Get the handler at the specified position.
-   *
    * @param index The position to get (0-based)
    * @return The handler at that position
    */
@@ -183,7 +176,6 @@ public PushConsumer get(int index) {
 
   /**
    * Get the number of handlers in the chain.
-   *
    * @return The number of handlers
    */
   public int size() {

src/main/java/redis/clients/jedis/PushConsumerContext.java

@@ -4,23 +4,23 @@
 
 @Internal
 public class PushConsumerContext {
-    private final PushMessage message;
-    private boolean processed = false;
+  private final PushMessage message;
+  private boolean processed = false;
 
-    public PushConsumerContext(PushMessage message) {
-        this.message = message;
-    }
+  public PushConsumerContext(PushMessage message) {
+    this.message = message;
+  }
 
-    public PushMessage getMessage() {
-        return message;
-    }
+  public PushMessage getMessage() {
+    return message;
+  }
 
-    public boolean isProcessed() {
-        return processed;
-    }
+  public boolean isProcessed() {
+    return processed;
+  }
 
-    public void setProcessed(boolean processed) {
-        this.processed = processed;
-    }
+  public void setProcessed(boolean processed) {
+    this.processed = processed;
+  }
 
 }

src/main/java/redis/clients/jedis/PushHandler.java

@@ -5,22 +5,19 @@
 
 /**
  * A handler object that provides access to {@link PushListener}s.
- *
  * @author Ivo Gaydajiev
  * @since 6.1
  */
 public interface PushHandler {
 
   /**
    * Add a new {@link PushListener listener}.
-   *
    * @param listener the listener, must not be {@code null}.
    */
   void addListener(PushListener listener);
 
   /**
    * Remove an existing {@link PushListener listener}.
-   *
    * @param listener the listener, must not be {@code null}.
    */
   void removeListener(PushListener listener);
@@ -32,22 +29,25 @@ public interface PushHandler {
 
   /**
    * Returns a collection of {@link PushListener}.
-   *
    * @return the collection of listeners.
    */
   Collection<PushListener> getPushListeners();
 
   /**
-   * A no-operation implementation of PushHandler that doesn't maintain any listeners.
+   * A no-operation implementation of PushHandler that doesn't maintain any listeners
+   *
+   * <p>
    * All operations are no-ops and getPushListeners() returns an empty list.
+   * </p>
    */
   PushHandler NOOP = new NoOpPushHandler();
 
 }
 
 final class NoOpPushHandler implements PushHandler {
 
-  NoOpPushHandler() {}
+  NoOpPushHandler() {
+  }
 
   @Override
   public void addListener(PushListener listener) {

src/main/java/redis/clients/jedis/PushListener.java

@@ -4,9 +4,8 @@
 public interface PushListener {
 
   /**
-   * Interface to be implemented by push message listeners that are interested in listening to {@link PushMessage}. Requires Redis
-   * 6+ using RESP3.
-   *
+   * Interface to be implemented by push message listeners that are interested in listening to
+   * {@link PushMessage}. Requires Redis 6+ using RESP3.
    * @author Ivo Gaydajiev
    * @since 6.1
    * @see PushMessage

src/main/java/redis/clients/jedis/PushMessage.java

@@ -15,11 +15,11 @@ public PushMessage(List<Object> content) {
     }
   }
 
- public  String getType(){
-    return  type;
+  public String getType() {
+    return type;
   }
 
-  public List<Object> getContent(){
+  public List<Object> getContent() {
     return content;
   }
 }

src/main/java/redis/clients/jedis/RebindAware.java

@@ -4,24 +4,24 @@
 
 /**
  * Interface for components that support rebinding to a new host and port.
- * Implementations of this interface can be notified when a Redis server sends
- * a MOVING notification during maintenance events.
- *
- * This interface can be implemented by various components such as:
- * - Connection pools
- * - Socket factories
- * - Connection providers
- * - Any component that manages connections to Redis servers
+ * <p>
+ * Implementations of this
+ * interface can be notified when a Redis server sends a MOVING notification during maintenance
+ * events. This interface can be implemented by various components such as: - Connection pools -
+ * Socket factories - Connection providers - Any component that manages connections to Redis servers
+ * </p>
  */
 @Experimental
 public interface RebindAware {
 
   /**
-   * Notifies the component that a re-bind to a new host and port is scheduled. This is called when
+   * Notifies the component that a re-bind to a new host and port is scheduled.
+   * <p>
+   * This is called when
    * a MOVING notification is received. Components that implement this interface should update their
    * internal state to reflect the new host and port, and return true if the re-bind was accepted.
-   * Components might decide to reject the re-bind request if they are not in a state to support
-   * it.
+   * Components might decide to reject the re-bind request if they are not in a state to support it.
+   * </p>
    * @param newHostAndPort The new host and port to use for new connections
    */
   void rebind(HostAndPort newHostAndPort);