xmlBlaster 2.1.0 API

org.xmlBlaster.util.dispatch
Class DispatchWorker

java.lang.Object
  extended by 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

Field Summary
private  I_DispatchManager dispatchManager
           
private static java.util.logging.Logger log
           
 java.lang.String ME
           
private  I_Queue msgQueue
           
 
Constructor Summary
DispatchWorker(Global glob, I_DispatchManager mgr)
           
 
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
 

Field Detail

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
Constructor Detail

DispatchWorker

public DispatchWorker(Global glob,
                      I_DispatchManager mgr)
Method Detail

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()

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.