Extending the framework
AccessAO, AccessAOBuilder ¿ PQL Documentation
GenericPush and GenericPull
New Wrapper
Transport Handler
Push
Example Transport Handler
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) { 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 ITransportExchangePattern getExchangePattern() { return ITransportExchangePattern.InOnly; }
Pull
Example Transport Handler
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; }
Existing Extensions
Scai