org.apache.sandesha2.workers
Class Sender

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

public class Sender
extends java.lang.Thread

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
 int SENDER_THREADPOOL_SIZE
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
Sender()
           
 
Method Summary
 boolean isSenderStarted()
           
 void run()
           
 void runSenderForTheSequence(org.apache.axis2.context.ConfigurationContext context, java.lang.String sequenceID)
           
 void stopSenderForTheSequence(java.lang.String sequenceID)
           
 void stopSending()
           
 
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
 

Field Detail

SENDER_THREADPOOL_SIZE

public int SENDER_THREADPOOL_SIZE
Constructor Detail

Sender

public Sender()
Method Detail

stopSenderForTheSequence

public void stopSenderForTheSequence(java.lang.String sequenceID)

stopSending

public void stopSending()

isSenderStarted

public boolean isSenderStarted()

run

public void run()

runSenderForTheSequence

public void runSenderForTheSequence(org.apache.axis2.context.ConfigurationContext context,
                                    java.lang.String sequenceID)


Copyright © 2005-2006 Apache Web Services. All Rights Reserved.