PollingManager (Apache Sandesha2)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.sandesha2.polling
Class PollingManager

java.lang.Object
  java.lang.Thread
      org.apache.sandesha2.workers.SandeshaThread
          org.apache.sandesha2.polling.PollingManager

All Implemented Interfaces:: java.lang.Runnable

public class PollingManager
extends SandeshaThread
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.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 -