commit e6b5623dbd6aea9e322a11ef6287aac57ce6b0c9
author Ryoichi Taniguchi <ryoichi.x.taniguchi@sonymobile.com> Wed Dec 16 13:34:44 2015 +0900
committer David Pursehouse <david.pursehouse@sonymobile.com> Wed Dec 16 15:00:18 2015 +0900
tree c3836dffd9f412f5d708a43dcb05ef72c101dc6f
parent 6ee0a32f594c42a656e9080083e924b34779a4ab

Add logging of cancelled replication events

Change-Id: I9a9b955b062b108f4e63bf45024a340a5c3246a8

src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java b/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java
index eea1038..dfeb174 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/Destination.java
@@ -190,6 +190,9 @@
   int shutdown() {
     int cnt = 0;
     if (pool != null) {
+      for (Runnable r : pool.getQueue()) {
+        repLog.warn(String.format("Cancelling replication event %s", r));
+      }
       cnt = pool.shutdownNow().size();
       pool.unregisterWorkQueue();
       pool = null;