edu.uci.isr.yancees.server.plugin.protocol.polling
Class MOPollProtocolPlugin.PollingMechanism

java.lang.Object
  extended byjava.lang.Thread
      extended byedu.uci.isr.yancees.server.plugin.protocol.polling.MOPollProtocolPlugin.PollingMechanism
All Implemented Interfaces:
java.lang.Runnable
Enclosing class:
MOPollProtocolPlugin

protected class MOPollProtocolPlugin.PollingMechanism
extends java.lang.Thread

Implements a thread that periodically polls all the pull plug-ins under the provides subscriber interface and publishes the output of this plug-in using the events stored in the pull plug-ins.


Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
MOPollProtocolPlugin.PollingMechanism(int interval, SubscriberInterface si, MOPollProtocolPlugin ownerPlugin)
           
 
Method Summary
 void pausePolling()
           
 void resumePolling()
           
 void run()
          Infinite loop that collects the events for the current subscriber, periodically, according to the pollInterval.
 void setPollInterval(int interval)
           
 void setSubscriber(SubscriberInterface si)
           
 void terminate()
           
 
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

MOPollProtocolPlugin.PollingMechanism

public MOPollProtocolPlugin.PollingMechanism(int interval,
                                             SubscriberInterface si,
                                             MOPollProtocolPlugin ownerPlugin)
Method Detail

run

public void run()
Infinite loop that collects the events for the current subscriber, periodically, according to the pollInterval. It publishes the output using the appropriate plug-in method.


pausePolling

public void pausePolling()

resumePolling

public void resumePolling()

setPollInterval

public void setPollInterval(int interval)

setSubscriber

public void setSubscriber(SubscriberInterface si)

terminate

public void terminate()