...
Code Block | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|
| ||||||||||
public class ExampleProtocolHandler<T> extends AbstractProtocolHandler<T> { public ExampleProtocolHandler() { super(); } public ExampleProtocolHandler(ITransportDirection direction, IAccessPattern access) { super(direction, access); } @Override public void open() throws UnknownHostException, IOException { getTransportHandler().open(); } @Override public void close() throws IOException { getTransportHandler().close(); } @Override public boolean hasNext() throws IOException { return true; } @Override public T getNext() throws IOException { return getDataHandler().readData("data"); } @Override public void write(T object) throws IOException { } @Override public IProtocolHandler<T> createInstance(ITransportDirection direction, IAccessPattern access, Map<String, String> options, IDataHandler<T> dataHandler, ITransferHandler<T> transfer) { ExampleProtocolHandler<T> instance = new ExampleProtocolHandler<T>(direction, access); instance.setDataHandler(dataHandler); instance.setTransfer(transfer); return// Set options return instance; } @Override public String getName() { return "Example"; } @Override public void onConnect(ITransportHandler caller) { // TODO Auto-generated method stub } @Override public void onDisonnect(ITransportHandler caller) { // TODO Auto-generated method stub } @Override public void process(ByteBuffer message) { getTransfer().transfer(getDataHandler().readData(message)); } } |
...