System.out.println("   DataStreamProducer thread interrupted and stopping ");
log.warn("   DataStreamProducer thread interrupted and stopping ");
   public final void run() {      boolean done = false;      me = Thread.currentThread();      // load the first response screen      try {         loadStream(abyte2, 0);      }      catch (IOException ioef) {         System.out.println(" run() " + ioef.getMessage());      }      while (!done) {         try {            byte[] abyte0 = readIncoming();            // WVL - LDC : 16/07/2003 : TR.000345            // When the socket has been closed, the reading returns            // no bytes (an empty byte arrray).            // But the loadStream fails on this, so we check it here!            if (abyte0.length > 0)            {              loadStream(abyte0, 0);            }            // WVL - LDC : 16/07/2003 : TR.000345            // Returning no bytes means the input buffer has            // reached end-of-stream, so we do a disconnect!            else            {              done = true;              vt.disconnect();            }         }         catch (SocketException se) {//            System.out.println("   DataStreamProducer thread interrupted and stopping " + se.getMessage());            System.out.println("   DataStreamProducer thread interrupted and stopping ");            done = true;         }         catch (IOException ioe) {//              System.out.println(ioe.getMessage());           if (me.isInterrupted())              done = true;         }         catch (Exception ex) {           System.out.println(ex.getMessage());           if (me.isInterrupted())              done = true;         }      }    }