public ForwardingListener(ConnectionProtocol connection,
    String addressToBind,
    int portToBind) 
{
        this(addressToBind + ":" + String.valueOf(portToBind), connection,
            addressToBind, portToBind, "[Specified by connecting computer]", -1);
}

Creates a new ForwardingListener object.

Parameters:

connection -

addressToBind -

portToBind -

 public ForwardingListener(String name,
    ConnectionProtocol connection,
    String addressToBind,
    int portToBind,
    String hostToConnect,
    int portToConnect) 
{
                          
        super(name, addressToBind, portToBind, hostToConnect, portToConnect);
        log.info("Creating forwarding listener named '" + name + "'");
        this.connection = connection;
        if (log.isDebugEnabled()) {
            log.debug("Address to bind: " + getAddressToBind());
            log.debug("Port to bind: " + String.valueOf(getPortToBind()));
            log.debug("Host to connect: " + hostToConnect);
            log.debug("Port to connect: " + portToConnect);
        }
}

Creates a new ForwardingListener object.

Parameters:

name -

connection -

addressToBind -

portToBind -

hostToConnect -

portToConnect -

 abstract protected ForwardingSocketChannel createChannel(String hostToConnect,
    int portToConnect,
    Socket socket) throws ForwardingConfigurationException

 public int getLocalPort() 
{
        return (server == null) ? (-1) : server.getLocalPort();
}

 public boolean isListening() 
{
        return listening;
}

 public boolean isRunning() 
{
        return (thread != null) && thread.isAlive();
}

 public  void run() 
{
        try {
            log.info("Starting forwarding listener thread for '" + name + "'");
            //
            //            ServerSocket server = new ServerSocket(getPortToBind(), 50, InetAddress.getByName(getAddressToBind()));
            //server = new ServerSocket(getPortToBind(), 50, InetAddress.getByName(getAddressToBind()));
            Socket socket;
            while (state.getValue() == StartStopState.STARTED) {
                listening = true;
                socket = server.accept();
                if ((state.getValue() == StartStopState.STOPPED) ||
                        (socket == null)) {
                    break;
                }
                log.info("Connection accepted, creating forwarding channel");
                try {
                    ForwardingSocketChannel channel = createChannel(hostToConnect,
                            portToConnect, socket);
                    channel.bindSocket(socket);
                    if (connection.openChannel(channel)) {
                        log.info("Forwarding channel for '" + name +
                            "' is open");
                    } else {
                        log.warn("Failed to open forwarding chanel " + name);
                        socket.close();
                    }
                } catch (Exception ex) {
                    log.warn("Failed to open forwarding chanel " + name, ex);
                    try {
                        socket.close();
                    } catch (IOException ioe) {
                    }
                }
            }
        } catch (IOException ioe) {
            /* only warn if the forwarding has not been stopped */
            if (state.getValue() == StartStopState.STARTED) {
                log.warn("Local forwarding listener to " + hostToConnect + ":" +
                    String.valueOf(portToConnect) + " has failed", ioe);
            }
        } finally {
            stop();
        }
}

 public  void start() throws IOException 
{
        /* Set the state by calling the super method */
        super.start();
        /* Bind server socket */
        try {
            server = new ServerSocket(getPortToBind(), 50,
                    InetAddress.getByName(getAddressToBind()));
        } catch (IOException ioe) {
            super.stop();
            throw ioe;
        }
        /* Create a thread and start it */
        thread = new SshThread(this, "Forwarding listener", true);
        /* Create a thread and start it */
        thread = new SshThread(this, "Forwarding listener", true);
        thread.start();
}

 public  void stop() 
{
        /* Set the state by calling the super method */
        super.stop();
        try {
            /* Close the server socket */
            if (server != null) {
                server.close();
            }
        } catch (IOException ioe) {
            log.warn("Forwarding listener failed to stop", ioe);
        }
        thread = null;
        listening = false;
}