THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
/**
* An AdjunctDataStoreManager instance is responsible for
* 1. maintaining the mapping between system streams and adjunct data stores
* 2. extracting the key and value from an IncomingMessageEnvelop
* 3. populating adjunct data stores
*/
public interface AdjunctDataStoreManager {
/**
* Invoked before a message is passed to a task
* @returns true if the message is saved in a store, false otherwise
*/
AdjunctDataStoreManager boolean process(IncomingMessageEnvelop message);
} |
ConverterFactory
Code Block |
---|
/** * A factory to instantiate converters */ public interface ConverterFactory { Converter getConvert(Config config); } |
Converter
Code Block |
---|
/** * A converter converts an input object to another type */ public interface Converter { /** * Converts an input object to another type * * @param input the object to be converted * @returns the converted object */ Object convert(Object input); } |
Public Interfaces
No changes to public interface
...