consumablequeueworker.java

java开源的企业总线.xmlBlaster

/*------------------------------------------------------------------------------
Name:      ConsumableQueueWorker.java
Project:   xmlBlaster.org
Copyright: xmlBlaster.org, see xmlBlaster-LICENSE file
------------------------------------------------------------------------------*/

package org.xmlBlaster.engine.distributor.plugins;

import java.util.logging.Logger;
import java.util.logging.Level;

/**
 * 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 <a href="mailto:[e-mail]">Michele Laghi</a>
 */
public class ConsumableQueueWorker implements Runnable {

   private static Logger log;
   private ConsumableQueuePlugin consumableQueuePlugin;

   public ConsumableQueueWorker(Logger log_, ConsumableQueuePlugin consumableQueuePlugin) {
      log = log_;
      if (log.isLoggable(Level.FINER)) log.finer("constructor");
      this.consumableQueuePlugin = consumableQueuePlugin;
   }


   public void run() {
      if (log.isLoggable(Level.FINER)) log.finer("run");
      this.consumableQueuePlugin.processHistoryQueue();
   }

}