org.jboss.ha.framework.server: protected class: DistributedReplicantManagerImpl.MembersPublisher

org.jboss.ha.framework.server
protected class: DistributedReplicantManagerImpl.MembersPublisher [javadoc | source]

java.lang.Object
   java.lang.Thread
      org.jboss.ha.framework.server.DistributedReplicantManagerImpl$MembersPublisher

All Implemented Interfaces:
Runnable

Fields inherited from java.lang.Thread:
MIN_PRIORITY, NORM_PRIORITY, MAX_PRIORITY

Constructor:
public MembersPublisher() { super("DRM Async Publisher#" + threadID.getAndIncrement()); }

Method from org.jboss.ha.framework.server.DistributedReplicantManagerImpl$MembersPublisher Summary:
run

Methods from java.lang.Thread:
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods from java.lang.Thread:

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods from java.lang.Object:
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.jboss.ha.framework.server.DistributedReplicantManagerImpl$MembersPublisher Detail:
public void run() { DistributedReplicantManagerImpl.this.log.debug("DRM: Sleeping before re-publishing for 50ms just in case"); try { // if this thread invokes a cluster method call before // membershipChanged event completes, it could timeout/hang // we need to discuss this with Bela. Thread.sleep(50); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } DistributedReplicantManagerImpl.this.republishLocalReplicants(); } Called when service needs to re-publish its local replicants to other cluster members after this node has joined the cluster.

Method from org.jboss.ha.framework.server.DistributedReplicantManagerImpl$MembersPublisher Detail:

 public  void run() {
         DistributedReplicantManagerImpl.this.log.debug("DRM: Sleeping before re-publishing for 50ms just in case");
         try
         {
            // if this thread invokes a cluster method call before
            // membershipChanged event completes, it could timeout/hang
            // we need to discuss this with Bela.
            Thread.sleep(50);
         }
         catch (InterruptedException e)
         {
            Thread.currentThread().interrupt();
         }
         DistributedReplicantManagerImpl.this.republishLocalReplicants();
}

Called when service needs to re-publish its local replicants to other cluster members after this node has joined the cluster.