org.xmlBlaster.util.dispatch
Class DispatchWorker
java.lang.Object
org.xmlBlaster.util.dispatch.DispatchWorker
- All Implemented Interfaces:
- java.lang.Runnable
public final class DispatchWorker
- extends java.lang.Object
- implements java.lang.Runnable
Takes messages from the queue and tries to send them back to a client.
- Author:
- xmlBlaster@marcelruff.info
Method Summary |
void |
run()
Asynchronous pull mode, invoked by DispatchWorkerPool.execute() -> see DispatchManager calling it |
void |
run(java.util.ArrayList entryList)
Synchronous push mode. |
void |
shutdown()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ME
public final java.lang.String ME
log
private static java.util.logging.Logger log
dispatchManager
private I_DispatchManager dispatchManager
msgQueue
private I_Queue msgQueue
DispatchWorker
public DispatchWorker(Global glob,
I_DispatchManager mgr)
run
public void run(java.util.ArrayList entryList)
throws XmlBlasterException
- Synchronous push mode.
The 'synchronous' ACK is transported in entryList(i).getReturnObj()
which contains pre parsed objects like SubscribeQosReturn etc.
- Throws:
XmlBlasterException
run
public void run()
- Asynchronous pull mode, invoked by DispatchWorkerPool.execute() -> see DispatchManager calling it
- Specified by:
run
in interface java.lang.Runnable
shutdown
public void shutdown()
Copyright © 1999-2014 The xmlBlaster.org contributers.