FileDocCategorySizeDatePackage
TelnetTestResponder.javaAPI DocApache Commons NET 1.4.1 API2915Sat Dec 03 10:05:50 GMT 2005org.apache.commons.net.telnet

TelnetTestResponder

public class TelnetTestResponder extends Object implements Runnable
Simple stream responder. Waits for strings on an input stream and answers sending corresponfing strings on an output stream. The reader runs in a separate thread.

author
Bruno D'Avanzo

Fields Summary
InputStream
_is
OutputStream
_os
String[]
_inputs
String[]
_outputs
long
_timeout
Constructors Summary
public TelnetTestResponder(InputStream is, OutputStream os, String[] inputs, String[] outputs, long timeout)
Constructor. Starts a new thread for the reader.

param
is - InputStream on which to read.
param
os - OutputStream on which to answer.
param
inputs - Array of waited for Strings.
param
inputs - Array of answers.

        _is = is;
        _os = os;
        _timeout = timeout;
        _inputs = inputs;
        _outputs = outputs;
        Thread reader = new Thread (this);

        reader.start();
Methods Summary
public voidrun()
Runs the responder

        boolean result = false;
        byte buffer[] = new byte[32];
        long starttime = System.currentTimeMillis();

        try
        {
            String readbytes = new String();
            while(!result &&
                  ((System.currentTimeMillis() - starttime) < _timeout))
            {
                if(_is.available() > 0)
                {
                    int ret_read = _is.read(buffer);
                    readbytes = readbytes + new String(buffer, 0, ret_read);

                    for(int ii=0; ii<_inputs.length; ii++)
                    {
                        if(readbytes.indexOf(_inputs[ii]) >= 0)
                        {
                            Thread.sleep(1000 * ii);
                            _os.write(_outputs[ii].getBytes());
                            result = true;
                        }
                    }
                }
                else
                {
                    Thread.sleep(500);
                }
            }

        }
        catch (Exception e)
        {
            System.err.println("Error while waiting endstring. " + e.getMessage());
        }