...
Code Block | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|
| ||||||||||
public class ExampleTransportHandler extends AbstractPushTransportHandler { /** Logger */ private Logger LOG = LoggerFactory.getLogger(ExampleTransportHandler.class); public ExampleTransportHandler() { super(); } public ExampleTransportHandler(IProtocolHandler<?> protocolHandler) { super(protocolHandler); } @Override public void send(byte[] message) throws IOException { } @Override public ITransportHandler createInstance( IProtocolHandler<?> protocolHandler, Map<String, String> options) { SpeechTransportHandlerExampleTransportHandler handler = new SpeechTransportHandlerExampleTransportHandler( protocolHandler); // Set options return handler; } @Override public String getName() { return "Example"; } @Override public void processInOpen() throws IOException { } @Override public void processOutOpen() throws IOException { } @Override public void processInClose() throws IOException { } @Override public void processOutClose() throws IOException { } @Override public ITransportExchangePattern getExchangePattern() { return ITransportExchangePattern.InOnly; } |
...
The implementation of a Pull Transport Handler is similar to the Push Transport Handler except the fact that ones has to implement the two methods getInputStream and getOutputStream that are used by a protocol handler to request the access the next data element.
Code Block | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|
| ||||||||||
public class ExampleTransportHandler extends AbstractPullTransportHandler { /** Logger */ private Logger LOG = LoggerFactory.getLogger(ExampleTransportHandler.class); private InputStream in; private outputStrem out; public ExampleTransportHandler() { super(); } public ExampleTransportHandler(IProtocolHandler<?> protocolHandler) { super(protocolHandler); } @Override public void send(byte[] message) throws IOException { } @Override public ITransportHandler createInstance( IProtocolHandler<?> protocolHandler, Map<String, String> options) { SpeechTransportHandler handler = new SpeechTransportHandler( protocolHandler); // Set options return handler; } @Override public String getName() { return "Example"; } @Override public void processInOpen() throws IOException { } @Override public void processOutOpen() throws IOException { } @Override public void processInClose() throws IOException { } @Override public void processOutClose() throws IOException { } @Override public InputStream getInputStream() { return in; } @Override public OutputStream getOutputStream() { return out; } @Override public ITransportExchangePattern getExchangePattern() { return ITransportExchangePattern.InOnly; } |
...