org.xmlBlaster.engine.distributor.plugins
Class ConsumableQueueWorker

java.lang.Object
  org.xmlBlaster.engine.distributor.plugins.ConsumableQueueWorker

All Implemented Interfaces:

java.lang.Runnable

public class ConsumableQueueWorker
extends java.lang.Object
implements java.lang.Runnable

ConsumableQueueWorker processes the distribution of messages on topics which have a ConsumableQueue plugin defined. This runs in its own thread, so when it is stared, the invoker thread can return without waiting for all messages to be processed.

Author:

Michele Laghi

Field Summary

private ConsumableQueuePlugin	consumableQueuePlugin
private static java.util.logging.Logger	log

Constructor Summary

ConsumableQueueWorker(java.util.logging.Logger log_, ConsumableQueuePlugin consumableQueuePlugin)

Method Summary

void

run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static java.util.logging.Logger log

consumableQueuePlugin

private ConsumableQueuePlugin consumableQueuePlugin

Constructor Detail

ConsumableQueueWorker

public ConsumableQueueWorker(java.util.logging.Logger log_,
                             ConsumableQueuePlugin consumableQueuePlugin)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable