org.jacorb.notification.engine
Class DefaultTaskFactory

java.lang.Object
  extended byorg.jacorb.notification.engine.DefaultTaskFactory
All Implemented Interfaces:
org.picocontainer.Disposable, Disposable, TaskFactory

public class DefaultTaskFactory
extends java.lang.Object
implements Disposable, TaskFactory

Version:
$Id: DefaultTaskFactory.java,v 1.5 2005/11/11 19:37:44 alphonse.bendt Exp $
Author:
Alphonse Bendt

Constructor Summary
DefaultTaskFactory(org.apache.avalon.framework.configuration.Configuration config)
           
 
Method Summary
 void dispose()
           
 void enqueueMessage(FilterProxySupplierTask task)
          factory method to create PushToConsumer Tasks.
 void enqueueMessage(FilterStage[] nodes, Message mesg)
           
 Schedulable newFilterConsumerAdminTask(FilterSupplierAdminTask oldTask)
           
 Schedulable newFilterProxyConsumerTask(Message message)
           
 Schedulable newFilterProxySupplierTask(FilterConsumerAdminTask task)
           
 Schedulable newFilterSupplierAdminTask(FilterProxyConsumerTask oldTask)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultTaskFactory

public DefaultTaskFactory(org.apache.avalon.framework.configuration.Configuration config)
Method Detail

dispose

public void dispose()
Specified by:
dispose in interface org.picocontainer.Disposable

newFilterProxyConsumerTask

public Schedulable newFilterProxyConsumerTask(Message message)
Specified by:
newFilterProxyConsumerTask in interface TaskFactory

newFilterSupplierAdminTask

public Schedulable newFilterSupplierAdminTask(FilterProxyConsumerTask oldTask)
Specified by:
newFilterSupplierAdminTask in interface TaskFactory

newFilterConsumerAdminTask

public Schedulable newFilterConsumerAdminTask(FilterSupplierAdminTask oldTask)
Specified by:
newFilterConsumerAdminTask in interface TaskFactory

newFilterProxySupplierTask

public Schedulable newFilterProxySupplierTask(FilterConsumerAdminTask task)
Specified by:
newFilterProxySupplierTask in interface TaskFactory

enqueueMessage

public void enqueueMessage(FilterStage[] nodes,
                           Message mesg)
Specified by:
enqueueMessage in interface TaskFactory

enqueueMessage

public void enqueueMessage(FilterProxySupplierTask task)
factory method to create PushToConsumer Tasks. The Tasks are initialized with the data taken from a FilterProxySupplierTask.

Specified by:
enqueueMessage in interface TaskFactory