1 21 22 package org.jacorb.notification.engine; 23 24 import org.jacorb.notification.interfaces.FilterStage; 25 import org.jacorb.notification.interfaces.Message; 26 27 31 public interface TaskFactory 32 { 33 public abstract Schedulable newFilterProxyConsumerTask(Message message); 34 35 public abstract Schedulable newFilterSupplierAdminTask(FilterProxyConsumerTask t); 36 37 public abstract Schedulable newFilterConsumerAdminTask(FilterSupplierAdminTask t); 38 39 public abstract Schedulable newFilterProxySupplierTask(FilterConsumerAdminTask task); 40 41 43 public abstract void enqueueMessage(FilterStage[] nodes, Message event); 44 45 49 public abstract void enqueueMessage(FilterProxySupplierTask task); 50 } | Popular Tags |