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, 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.

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,
                      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