cgl.narada.wsinfra.wsrm.impl
Class WsrmSequenceMonitorImpl

java.lang.Object
  java.lang.Thread
      cgl.narada.wsinfra.wsrm.impl.WsrmSequenceMonitorImpl

All Implemented Interfaces:

Runnable, WsrmSequenceMonitor

public class WsrmSequenceMonitorImpl

extends Thread

implements WsrmSequenceMonitor

This processor processes Sequences and determines if (a) Acknowledgements/Retransmissions need to be issued. (b) See if the Inactivity timeout on a sequence has expired, if so proceed to terminate the sequence.

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

protected

WsrmSequenceMonitorImpl(String configInfo, WsMessageFlow wsMessageFlow)

Method Summary

boolean	checkIfMessagesAvailable(WsrmSequenceInfo wsrmSequenceInfo)
boolean	checkInactivityTimeout(WsrmSequenceInfo wsrmSequenceInfo)
void	checkToIssueAcknowledgements(WsrmSequenceInfo wsrmSequenceInfo)
void	checkToIssueRetransmissions(WsrmSequenceInfo wsrmSequenceInfo)
void	run()
void	startServices()
void	stopServices()

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

WsrmSequenceMonitorImpl

protected WsrmSequenceMonitorImpl(String configInfo,
                                  WsMessageFlow wsMessageFlow)
                           throws WsrmStorageException

Method Detail

startServices

public void startServices()

Specified by:

startServices in interface WsrmSequenceMonitor

stopServices

public void stopServices()

Specified by:

stopServices in interface WsrmSequenceMonitor

run

public void run()

Specified by:

run in interface Runnable

checkInactivityTimeout

public boolean checkInactivityTimeout(WsrmSequenceInfo wsrmSequenceInfo)
                               throws WsrmStorageException

Specified by:

checkInactivityTimeout in interface WsrmSequenceMonitor

Throws:

WsrmStorageException

checkIfMessagesAvailable

public boolean checkIfMessagesAvailable(WsrmSequenceInfo wsrmSequenceInfo)
                                 throws WsrmStorageException

Specified by:

checkIfMessagesAvailable in interface WsrmSequenceMonitor

Throws:

WsrmStorageException

checkToIssueAcknowledgements

public void checkToIssueAcknowledgements(WsrmSequenceInfo wsrmSequenceInfo)
                                  throws MessageFlowException,
                                         WsrmStorageException

Specified by:

checkToIssueAcknowledgements in interface WsrmSequenceMonitor

Throws:

MessageFlowException

WsrmStorageException

checkToIssueRetransmissions

public void checkToIssueRetransmissions(WsrmSequenceInfo wsrmSequenceInfo)
                                 throws WsrmStorageException,
                                        MessageFlowException

Specified by:

checkToIssueRetransmissions in interface WsrmSequenceMonitor

Throws:

WsrmStorageException

MessageFlowException