org.jacorb.notification.engine
Class DefaultTaskFactory
java.lang.Object
org.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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultTaskFactory
public DefaultTaskFactory(org.apache.avalon.framework.configuration.Configuration config)
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