xmlBlaster 2.2.0 client 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
 java.lang.String ME
           
 
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
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.2.0 client API

Copyright © 1999-2014 The xmlBlaster.org contributers.