public FutureResponse asyncRequest(Object command,
    ResponseCallback responseCallback) throws IOException 
{
        throw new AssertionError("Unsupported Method");
}

 protected  void checkStarted() throws IOException 
{
        if (!isStarted()) {
            throw new IOException("The transport is not running.");
        }
}

 public  void doConsume(Object command) 
{
        if (command != null) {
            if (transportListener != null) {
                transportListener.onCommand(command);
            } else {
                LOG.error("No transportListener available to process inbound command: " + command);
            }
        }
}

Process the inbound command

 public TransportListener getTransportListener() 
{
              
        return transportListener;
}

Returns the current transport listener

 public boolean isConnected() 
{
	    return isStarted();
}

 public boolean isDisposed() 
{
		return isStopped();
}

 public boolean isFaultTolerant() 
{
        return false;
}

 public T narrow(Class target) 
{
        boolean assignableFrom = target.isAssignableFrom(getClass());
        if (assignableFrom) {
            return target.cast(this);
        }
        return null;
}

narrow acceptance

 public  void onException(IOException e) 
{
        if (transportListener != null) {
            transportListener.onException(e);
        }
}

Passes any IO exceptions into the transport listener

 public  void reconnect(URI uri) throws IOException 
{
		throw new IOException("Not supported");
}

 public Object request(Object command) throws IOException 
{
        throw new AssertionError("Unsupported Method");
}

 public Object request(Object command,
    int timeout) throws IOException 
{
        throw new AssertionError("Unsupported Method");
}

 public  void setTransportListener(TransportListener commandListener) 
{
        this.transportListener = commandListener;
}

Registers an inbound command listener