xmlBlaster 2.1.0 API

org.xmlBlaster.engine.distributor.plugins
Class ConsumableQueueWorker

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

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.