how to fix broken pipe error in Java Application running on RedHat

I have a Java proxy server, which is public to the client,  the client connects to the destination server through proxy server with SSL. The proxy server and destination server both got "Broken Pipe" Error, when the servers sent out xml messages. this happens intermittently. BTW, everything was fine when applications was running on windows until they were moved on to Linux. Can some experts help me out?

Following is the part code of proxy server pipe for fowarding messages to the destination server and sending messages back to the client.

protected class Pipe extends Thread
  {
    private BufferedInputStream inStream;
    private BufferedOutputStream outStream;
    private String label;
   
    public Pipe(Socket in, Socket out, String label) throws IOException
    {
        super("Pipe");
      inStream = new BufferedInputStream(in.getInputStream(), BUFFER_SIZE);
      outStream = new BufferedOutputStream(out.getOutputStream(), BUFFER_SIZE);
      this.label = label + " " + in.getInetAddress().getHostAddress()
      + " -> " + out.getInetAddress().getHostAddress();
    }
   
    public void run()
    {
      byte[] bytes = new byte[BUFFER_SIZE];
      try
      {
        while (isRunning())
        {
          int count = inStream.read(bytes);
         
          if (count > 0)
          {
            long readTime = System.currentTimeMillis();
            outStream.write(bytes,0,count);
            outStream.flush();
            Thread.yield();
           
            //transfer statistics
            getServerTypeStatistics().
            stat(ProxyByTypeStatistics.TRANSFER,count);
          }
          else if (count < 0)
            throw new EOFException("Normal End of Stream");
          else if (count == 0)
            try
            {
              Thread.sleep(SLEEP_TIME);
            }
            catch (InterruptedException ie)
            {
            }
        }
      }
      catch (EOFException eofe)
      {
        if ( running )
        {
          Log.getLog().log("INFO",label+" EOF: Socket closed");
          shutdown();
        }
      }
      catch (IOException ioe)
      {
        if ( running )
        {
          Log.getLog().log("ERROR","PIPE ERROR"+label);
          Log.getLog().log("ERROR",ioe);

          shutdown();
        }
      }
      catch (Throwable e)
      {
          Log.getLog().log("ERROR",e);
      }
      finally
      {
       
        try
        {
          inStream.close();
          outStream.close();
        }
        catch (IOException ioe)
        {
        }
      }
    }
  }
}