// Add TransportFilter, which is responsible
// for reading and writing data to the connection
filterChainBuilder.add(new TransportFilter());
filterChainBuilder.add(new RexProClientFilter());
filterChainBuilder.add(new BaseFilter() {
@Override
public NextAction handleRead(FilterChainContext ctx) throws IOException {
responseQueue.add((RexProMessage) ctx.getMessage());
return ctx.getStopAction();
}