1 files changed, 11 insertions, 1 deletions
diff --git a/base/common/src/com/netscape/cmscore/connector/Resender.java b/base/common/src/com/netscape/cmscore/connector/Resender.java
index e1b19749a..64a99820a 100644
--- a/base/common/src/com/netscape/cmscore/connector/Resender.java
+++ b/base/common/src/com/netscape/cmscore/connector/Resender.java
@@ -49,6 +49,14 @@ public class Resender implements IResender {
     IRequestQueue mQueue = null;
     protected IRemoteAuthority mDest = null;
 
+    public boolean isShutdown() {
+        return shutdown;
+    }
+
+    public void setShutdown(boolean shutdown) {
+        this.shutdown = shutdown;
+    }
+
     /* Vector of Request Id *Strings* */
     protected Vector<String> mRequestIds = new Vector<String>();
 
@@ -61,6 +69,8 @@ public class Resender implements IResender {
     // was down (versus being serviced in request queue)
     protected int mInterval = 1 * MINUTE;
 
+    protected volatile boolean shutdown = false;
+
     public Resender(IAuthority authority, String nickName, IRemoteAuthority dest) {
         mAuthority = authority;
         mQueue = mAuthority.getRequestQueue();
@@ -125,7 +135,7 @@ public class Resender implements IResender {
                 mAuthority.log(ILogger.LL_INFO, CMS.getLogMessage("CMSCORE_CONNECTOR_RESENDER_INTERRUPTED"));
                 continue;
             }
-        } while (true);
+        } while (!shutdown);
     }
 
     private void resend() {