Class Invoker

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

public class Invoker
extends SandeshaThread

This is used when InOrder invocation is required. This is a seperated Thread that keep running all the time. At each iteration it checks the InvokerTable to find weather there are any messages to me invoked.

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
static void forceInvokeOfAllMessagesCurrentlyOnSequence(org.apache.axis2.context.ConfigurationContext ctx, java.lang.String sequenceID, boolean allowLaterDeliveryOfMissingMessages)
          Forces dispatch of queued messages to the application.
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, 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 Invoker()
Method Detail


public static void forceInvokeOfAllMessagesCurrentlyOnSequence(org.apache.axis2.context.ConfigurationContext ctx,
                                                               java.lang.String sequenceID,
                                                               boolean allowLaterDeliveryOfMissingMessages)
                                                        throws SandeshaException
Forces dispatch of queued messages to the application. NOTE: may break ordering

ctx -
sequenceID -
allowLaterDeliveryOfMissingMessages - if true, messages skipped over during this action will be invoked if they arrive on the system at a later time. Otherwise messages skipped over will be ignored


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.