org.apache.sandesha2.polling
Class PollingManager

java.lang.Object
  extended by java.lang.Thread
      extended by org.apache.sandesha2.workers.SandeshaThread
          extended by org.apache.sandesha2.polling.PollingManager
All Implemented Interfaces:
java.lang.Runnable

public class PollingManager
extends SandeshaThread

This class is responsible for sending MakeConnection requests. This is a seperate thread that keeps running. Will do MakeConnection based on the request queue or randomly.


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class org.apache.sandesha2.workers.SandeshaThread
context, storageManager, threadPool
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
PollingManager()
           
 
Method Summary
protected  boolean internalRun()
          The main work loop, to be implemented by any child class.
 void schedulePollingRequest(java.lang.String sequenceId, boolean rmSource)
          Asking the polling manager to do a polling request on the sequence identified by the given InternalSequenceId.
 
Methods inherited from class org.apache.sandesha2.workers.SandeshaThread
blockForPause, doPauseIfNeeded, finishPause, getSequences, getWorkerLock, hasStoppedRunning, isThreadStarted, run, runMainLoop, runThreadForSequence, setRanMainLoop, stopRunning, stopThreadForSequence, wakeThread
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, 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, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PollingManager

public PollingManager()
Method Detail

internalRun

protected boolean internalRun()
Description copied from class: SandeshaThread
The main work loop, to be implemented by any child class. If the child wants to sleep before the next loop then they should return true.

Specified by:
internalRun in class SandeshaThread

schedulePollingRequest

public void schedulePollingRequest(java.lang.String sequenceId,
                                   boolean rmSource)
Asking the polling manager to do a polling request on the sequence identified by the given InternalSequenceId.

Parameters:
sequenceId -


Copyright © The Apache Software Foundation. All Rights Reserved.