Sender (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.workers
Class Sender

java.lang.Object
  java.lang.Thread
      org.apache.sandesha2.workers.SandeshaThread
          org.apache.sandesha2.workers.Sender

All Implemented Interfaces:: java.lang.Runnable

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

Sender

public Sender()

Method Detail

scheduleAddressableAcknowledgement

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

removeScheduledAcknowledgement

public void removeScheduledAcknowledgement(java.lang.String sequenceId)

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