...
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); } |
...