org.openorb.notify.queue
public class Pusher extends NotifyThread
Constructor Summary | |
---|---|
Pusher(String id, EventQueue queue, ConsumerProxyManagement proxy, ORB orb, Logger logger)
Default constructor.
|
Method Summary | |
---|---|
void | finishWorkAndStopThread()
Finish pending work and stop the thread |
void | pushEvent(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. |
Parameters: id The id. queue The event queue. proxy The consumer proxy management. orb The ORB. logger The logger.
Parameters: event The event to push.
Parameters: isConnectionActive Indicates if connection is active.
Parameters: propertiesRepository the properties repository.