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