public TransportFilter(Transport next) 
{
        this.next = next;
}

 public FutureResponse asyncRequest(Object command,
    ResponseCallback responseCallback) throws IOException 
{
        return next.asyncRequest(command, null);
}

 public Transport getNext() 
{
        return next;
}

 public String getRemoteAddress() 
{
        return next.getRemoteAddress();
}

 public TransportListener getTransportListener() 
{
        return transportListener;
}

 public boolean isConnected() 
{
        return next.isConnected();
}

 public boolean isDisposed() 
{
		return next.isDisposed();
}

 public boolean isFaultTolerant() 
{
        return next.isFaultTolerant();
}

 public T narrow(Class target) 
{
        if (target.isAssignableFrom(getClass())) {
            return target.cast(this);
        }
        return next.narrow(target);
}

 public  void onCommand(Object command) 
{
        transportListener.onCommand(command);
}

 public  void onException(IOException error) 
{
        transportListener.onException(error);
}

 public  void oneway(Object command) throws IOException 
{
        next.oneway(command);
}

 public  void reconnect(URI uri) throws IOException 
{
		next.reconnect(uri);
}

 public Object request(Object command) throws IOException 
{
        return next.request(command);
}

 public Object request(Object command,
    int timeout) throws IOException 
{
        return next.request(command, timeout);
}

 public  void setTransportListener(TransportListener channelListener) 
{
        this.transportListener = channelListener;
        if (channelListener == null) {
            next.setTransportListener(null);
        } else {
            next.setTransportListener(this);
        }
}

 public  void start() throws Exception 
{
        if (next == null) {
            throw new IOException("The next channel has not been set.");
        }
        if (transportListener == null) {
            throw new IOException("The command listener has not been set.");
        }
        next.start();
}

 public  void stop() throws Exception 
{
        next.stop();
}

 public String toString() 
{
        return next.toString();
}

 public  void transportInterupted() 
{
        transportListener.transportInterupted();
}

 public  void transportResumed() 
{
        transportListener.transportResumed();
}