diff options
Diffstat (limited to 'base/common/src/com/netscape/cmscore/connector/Resender.java')
-rw-r--r-- | base/common/src/com/netscape/cmscore/connector/Resender.java | 12 |
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() { |