org.jacorb.notification.engine

Class DefaultTaskFactory

public class DefaultTaskFactory extends 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(Configuration config)
Method Summary
voiddispose()
voidenqueueMessage(FilterStage[] nodes, Message mesg)
voidenqueueMessage(FilterProxySupplierTask task)
factory method to create PushToConsumer Tasks.
SchedulablenewFilterConsumerAdminTask(FilterSupplierAdminTask oldTask)
SchedulablenewFilterProxyConsumerTask(Message message)
SchedulablenewFilterProxySupplierTask(FilterConsumerAdminTask task)
SchedulablenewFilterSupplierAdminTask(FilterProxyConsumerTask oldTask)

Constructor Detail

DefaultTaskFactory

public DefaultTaskFactory(Configuration config)

Method Detail

dispose

public void dispose()

enqueueMessage

public void enqueueMessage(FilterStage[] nodes, Message mesg)

enqueueMessage

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

newFilterConsumerAdminTask

public Schedulable newFilterConsumerAdminTask(FilterSupplierAdminTask oldTask)

newFilterProxyConsumerTask

public Schedulable newFilterProxyConsumerTask(Message message)

newFilterProxySupplierTask

public Schedulable newFilterProxySupplierTask(FilterConsumerAdminTask task)

newFilterSupplierAdminTask

public Schedulable newFilterSupplierAdminTask(FilterProxyConsumerTask oldTask)