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

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