...
Code Block | ||
---|---|---|
| ||
public YourProtocolHandler() {
super();
}
public YourProtocolHandler(ITransportDirection direction, IAccessPattern access, OptionMap options,
IStreamObjectDataHandler<T> dataHandler) {
super(direction, access, dataHandler, options);
}
/**
* Creates a new protocol handler
* @param direction is this handler used in a source (IN) or in a sink (OUT)
* @param access which kind of access pattern is supported ( PUSH, PULL, ROBUST_PUSH, ROBUST_PULL)
* @param options set of options as key value pairs
* @param dataHandler the data handler thats connected to the protocol handler
* @return
*/
public IProtocolHandler<T> createInstance(ITransportDirection direction, IAccessPattern access,
Map<String, String> options, IDataHandler<T> dataHandler) {
return new YourProtocolHandler<>(direction, access, options, dataHandler);
} |
...