Page History

/**
 * An AdjunctDataStoreManager instances managesinstance is responsible for
 * 1. maintaining the mapping between system streams and adjunct data stores for a task
 * 2. populating adjunct data stores
 */
public interface AdjunctDataStoreManager {
    AdjunctDataStoreManager process(String taskName, IncomingMessageEnvelop message);
}