Socket s = ss.accept();
                InputStream input = s.getInputStream();
                 final  OutputStream output = s.getOutputStream();
                 new  Thread() {
                     public   void  run() {
                         while  (true) {
                             try  {
                                ik++;
                                String msg = "Hello # " + ik;
                                System.err.print("Send..." + msg);
                                output.write(msg.getBytes());
                                output.flush();
                                System.err.println(" OK!");
                            }  catch  (Throwable ioe) {
                                System.err.println(" WRONG!");
                                 break ;
                            }
                             try  {
                                Thread.sleep( 300 );
                            }  catch  (Exception ioe) {
                            }
                        }
                    }
                }.start();

     private   void  initSocket() {
         try  {
             if  (socket ==  null  || socket.isClosed() == true
                    || socket.isConnected() == false) {
                socket =  new  Socket();
                socket.connect(socketAddress,  5000 );
            }
        }  catch  (Throwable t) {
            System.err.println(t);
        }
    }

     private   void  closeSocket() {
         try  {
             if  (socket !=  null  && socket.isClosed() == false) {
                socket.close();
            }
        }  catch  (Throwable t) {
            System.err.println(t);
        }
    }

     private   byte [] buffer =  new   byte [ 1024 ];

     public   void  run() {
         while  (isActive) {
             try  {
                notifyDataListener( 1 );
                initSocket();
                InputStream input = socket.getInputStream();
                 int  length = input.read(buffer);
                 if  (length <  0 ) {
                     throw   new  EOFException("Was got -1");
                }
                notifyDataListener( 2 );
            }  catch  (Throwable t) {
                notifyDataListener( 3 );
                closeSocket();
                 try  {
                    Thread.sleep( 3000 );
                }  catch  (InterruptedException ie) {
                }
            }
        }
    }

     private   void  notifyDataListener( int  typeNotify) {
         try  {
             if  (dataListener !=  null ) {
                 switch  (typeNotify) {
                 case   1 :
                    dataListener.onStart();
                     break ;
                 case   2 :
                    dataListener.onRead();
                     break ;
                 case   3 :
                    dataListener.onError();
                     break ;
                }
            }
        }  catch  (Throwable t) {
            t.printStackTrace();
        }
    }