public interface TaskFactory
Modifier and Type | Method and Description |
---|---|
void |
enqueueMessage(FilterProxySupplierTask previousTask)
factory method to create PushToConsumer Tasks.
|
void |
enqueueMessage(FilterStage[] nodes,
Message event) |
Schedulable |
newFilterConsumerAdminTask(FilterSupplierAdminTask previousTask) |
Schedulable |
newFilterProxyConsumerTask(Message message) |
Schedulable |
newFilterProxySupplierTask(FilterConsumerAdminTask previousTask) |
Schedulable |
newFilterSupplierAdminTask(FilterProxyConsumerTask previousTask) |
Schedulable newFilterProxyConsumerTask(Message message)
Schedulable newFilterSupplierAdminTask(FilterProxyConsumerTask previousTask)
Schedulable newFilterConsumerAdminTask(FilterSupplierAdminTask previousTask)
Schedulable newFilterProxySupplierTask(FilterConsumerAdminTask previousTask)
void enqueueMessage(FilterStage[] nodes, Message event)
void enqueueMessage(FilterProxySupplierTask previousTask)