Class Sender

  extended by java.lang.Thread
      extended by org.apache.sandesha2.workers.SandeshaThread
          extended by org.apache.sandesha2.workers.Sender
All Implemented Interfaces:

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.

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
Constructor Summary
Method Summary
protected  boolean internalRun()
          The main work loop, to be implemented by any child class.
 void removeScheduledAcknowledgement(java.lang.String sequenceId)
 void scheduleAddressableAcknowledgement(java.lang.String sequenceId, long ackInterval, RMMsgContext ref)
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


public Sender()
Method Detail


public void scheduleAddressableAcknowledgement(java.lang.String sequenceId,
                                               long ackInterval,
                                               RMMsgContext ref)


public void removeScheduledAcknowledgement(java.lang.String sequenceId)


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 © The Apache Software Foundation. All Rights Reserved.