1 files changed, 23 insertions, 16 deletions
diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/PushResultProcessing.java b/src/main/java/com/googlesource/gerrit/plugins/replication/PushResultProcessing.java
index 6717660..0c3e158 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/PushResultProcessing.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/PushResultProcessing.java
@@ -17,21 +17,22 @@ package com.googlesource.gerrit.plugins.replication;
 import com.google.gerrit.common.EventDispatcher;
 import com.google.gerrit.server.events.RefEvent;
 import com.google.gwtorm.server.OrmException;
-
 import com.googlesource.gerrit.plugins.replication.ReplicationState.RefPushResult;
-
+import java.lang.ref.WeakReference;
+import java.util.concurrent.atomic.AtomicBoolean;
 import org.eclipse.jgit.transport.RemoteRefUpdate;
 import org.eclipse.jgit.transport.URIish;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.lang.ref.WeakReference;
-import java.util.concurrent.atomic.AtomicBoolean;
-
 public abstract class PushResultProcessing {
 
-  abstract void onRefReplicatedToOneNode(String project, String ref,
-      URIish uri, RefPushResult status, RemoteRefUpdate.Status refStatus);
+  abstract void onRefReplicatedToOneNode(
+      String project,
+      String ref,
+      URIish uri,
+      RefPushResult status,
+      RemoteRefUpdate.Status refStatus);
 
   abstract void onRefReplicatedToAllNodes(String project, String ref, int nodesCount);
 
@@ -55,7 +56,7 @@ public abstract class PushResultProcessing {
     // Default doing nothing
   }
 
-  private static String resolveNodeName(URIish uri) {
+  static String resolveNodeName(URIish uri) {
     StringBuilder sb = new StringBuilder();
     if (uri.isRemote()) {
       sb.append(uri.getHost());
@@ -78,8 +79,12 @@ public abstract class PushResultProcessing {
     }
 
     @Override
-    void onRefReplicatedToOneNode(String project, String ref, URIish uri,
-        RefPushResult status, RemoteRefUpdate.Status refStatus) {
+    void onRefReplicatedToOneNode(
+        String project,
+        String ref,
+        URIish uri,
+        RefPushResult status,
+        RemoteRefUpdate.Status refStatus) {
       StringBuilder sb = new StringBuilder();
       sb.append("Replicate ");
       sb.append(project);
@@ -162,10 +167,13 @@ public abstract class PushResultProcessing {
     }
 
     @Override
-    void onRefReplicatedToOneNode(String project, String ref, URIish uri,
-        RefPushResult status, RemoteRefUpdate.Status refStatus) {
-      postEvent(new RefReplicatedEvent(project, ref, resolveNodeName(uri),
-          status, refStatus));
+    void onRefReplicatedToOneNode(
+        String project,
+        String ref,
+        URIish uri,
+        RefPushResult status,
+        RemoteRefUpdate.Status refStatus) {
+      postEvent(new RefReplicatedEvent(project, ref, resolveNodeName(uri), status, refStatus));
     }
 
     @Override
@@ -174,8 +182,7 @@ public abstract class PushResultProcessing {
     }
 
     @Override
-    void onAllRefsReplicatedToAllNodes(int totalPushTasksCount) {
-    }
+    void onAllRefsReplicatedToAllNodes(int totalPushTasksCount) {}
 
     private void postEvent(RefEvent event) {
       try {