public class DefaultTaskFactory extends Object implements Disposable, TaskFactory
Constructor and Description |
---|
DefaultTaskFactory(Configuration config) |
Modifier and Type | Method and Description |
---|---|
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) |
public DefaultTaskFactory(Configuration config)
public void dispose()
public Schedulable newFilterProxyConsumerTask(Message message)
newFilterProxyConsumerTask
in interface TaskFactory
public Schedulable newFilterSupplierAdminTask(FilterProxyConsumerTask oldTask)
newFilterSupplierAdminTask
in interface TaskFactory
public Schedulable newFilterConsumerAdminTask(FilterSupplierAdminTask oldTask)
newFilterConsumerAdminTask
in interface TaskFactory
public Schedulable newFilterProxySupplierTask(FilterConsumerAdminTask task)
newFilterProxySupplierTask
in interface TaskFactory
public void enqueueMessage(FilterStage[] nodes, Message mesg)
enqueueMessage
in interface TaskFactory
public void enqueueMessage(FilterProxySupplierTask task)
enqueueMessage
in interface TaskFactory
Copyright © 2017 JacORB. All rights reserved.