|
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.openorb.notify.NotifyThread
org.openorb.notify.queue.Pusher
public class Pusher
This class is the base class for the various types of Pusher subclasses (e.g. AnyPusher, SequencePusher, etc) and contains all of the common code.
Constructor Summary | |
---|---|
Pusher(java.lang.String id,
EventQueue queue,
ConsumerProxyManagement proxy,
org.omg.CORBA.ORB orb,
org.apache.avalon.framework.logger.Logger logger)
Default constructor. |
Method Summary | |
---|---|
void |
finishWorkAndStopThread()
Finish pending work and stop the thread |
void |
pushEvent(java.lang.Object event)
This method is invoked by the proxy upon receipt of a new event. |
void |
run()
The run method waits for new events and pushes them in the queue. |
void |
setConnectionActive(boolean isConnectionActive)
This method sets the connection activity. |
void |
setConsumer(ConsumerAdapter consumer)
This method sets a consumer |
void |
setPropertiesRepository(PropertiesRepository propertiesRepository)
Sets the properties repository. |
void |
stopThread()
Stop the thread. |
Methods inherited from class org.openorb.notify.NotifyThread |
---|
getLogger, resumeThread, startThread, suspendThread, toString |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public Pusher(java.lang.String id, EventQueue queue, ConsumerProxyManagement proxy, org.omg.CORBA.ORB orb, org.apache.avalon.framework.logger.Logger logger)
id
- The id.queue
- The event queue.proxy
- The consumer proxy management.orb
- The ORB.logger
- The logger.Method Detail |
---|
public void setConnectionActive(boolean isConnectionActive)
isConnectionActive
- Indicates if connection is active.public void pushEvent(java.lang.Object event)
event
- The event to push.public void setConsumer(ConsumerAdapter consumer)
public void run()
public void stopThread()
stopThread
in interface ThreadManagement
stopThread
in class NotifyThread
public void finishWorkAndStopThread()
finishWorkAndStopThread
in interface ThreadManagement
finishWorkAndStopThread
in class NotifyThread
public void setPropertiesRepository(PropertiesRepository propertiesRepository)
propertiesRepository
- the properties repository.
|
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |