org.apache.sandesha2.workers
Class Sender

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.apache.sandesha2.workers.SandeshaThread
          extended byorg.apache.sandesha2.workers.Sender
All Implemented Interfaces:
java.lang.Runnable

public class Sender
extends SandeshaThread

This is responsible for sending and re-sending messages of Sandesha2. This represent a thread that keep running all the time. This keep looking at the Sender table to find out any entries that should be sent.


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
Sender()
           
 
Method Summary
protected  boolean internalRun()
          The main work loop, to be implemented by any child class.
 
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, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

Sender

public Sender()
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


Copyright © 2007 Apache Web Services Project. All Rights Reserved.