CLOSE_WAIT issue with java.net sockets

But I'm closing my socket connections properly. My application and system becoming slow when CLOSE_WAIT are too many. The only way is to restrat the application which is not possible in production environment. My web server is tomcat 5.5 and OS is windows xp or windows 2003.

You're using finally blocks are you?

Yes. Here's my thread run code and client socket async method.
public void run()
      {
            //log.debug("NEManager run() entry");
            log.debug("NEManager run() entry");
            ObjectOutputStream outStream = null;
            ObjectInputStream inStream = null;
            ResponseObject objRes = null;
            final String MSG = "CLOSE";
            final int POLL_NETWORK_SOCKET_TIMEOUT = 10000;
            Runtime rt = Runtime.getRuntime();
            try
            {
                   outStream = new ObjectOutputStream(this.neSocket.getOutputStream());
                   inStream = new ObjectInputStream(this.neSocket.getInputStream());

                  // Read the request object
                  RequestObject objReq = (RequestObject) inStream.readObject();
                  log.debug("Request Object Received");
                  if (objReq.getOpCode() != OperationalCode.POLL_NETWORK)
                  {
                        objReq.printObject(log);
                  }                  
                  
                  // Process the request and construct the response
                  objRes = new ResponseObject();
                  HashMap errType = new HashMap<String, Integer>();
                  objRes.setErrorType(errType);
                  boolean bResult = processRequest(objReq, objRes);                  
                  log.debug("Response Object to Operation Requester");
                  
                  //Added for avoiding socket CLOSE_WAIT problem
                  if (objReq.getOpCode() != OperationalCode.POLL_NETWORK)
                  {
                        outStream.writeObject(objRes);
                        outStream.flush();
                        this.neSocket.setSoLinger(true, 30000);
                        inStream.close();
                        outStream.close();
                  }                        
                  else
                  {                        
                        log.debug("NEManager >> run >> Poll network socket is closing ");
                        this.neSocket.setSoLinger(true, POLL_NETWORK_SOCKET_TIMEOUT);
                        outStream.writeBytes(MSG);
                        outStream.flush();                                    
                        inStream.close();
                        outStream.close();                  
                  }                                          

            }
            catch (Exception ex)
            {
                  log.error("Unknown Exception Raised", ex);                  
                  System.out.println("Exception OCCURRED IN NEMANAGER " + ex.getCause() + ex.getMessage());                  
                  //closeSocket(this.neSocket);
            }
            finally
            {
                        
                  try {                                          
                        this.neSocket.close();
                        this.neSocket = null;                        
                        log.debug("NEManager >> run >> Socket is closed ");
                  } catch (IOException e) {                        
                        log.debug("IOEXCEPTION OCCURRESD IN NEMANAGER " + e.getMessage());
                  }            
            
                        
            }
            log.debug("NEManager run() exit");
      }
====================================================================================
public int asyncSend(RequestObject inPackets,ResponseObject outPackets)
      {
                int returnCode = -1;
                final String RECV_MSG = "CLOSE";
            try {
                  log.info ("Initiating async send for Poll Network operation ");                  
                  theSocket.setSoTimeout(10000);
                  theSocket.setSoLinger(true, 10000);
                  outStream = new ObjectOutputStream (theSocket.getOutputStream());
                  inStream = new ObjectInputStream (theSocket.getInputStream());                  
                  // Store the requestID
                  String reqID = inPackets.getReqID().toString().trim();                  
                  outStream.writeObject (inPackets );
                  outStream.flush();
                  inPackets.printObject(log);
                  log.info("ClientSocketProtocol >> asyncsend >> Poll network Request sent to the Server");                  
                  returnCode = NWMErrorCode.SUCCESS;                  
                  String msg = inStream.readLine();
                  if(msg.equalsIgnoreCase(RECV_MSG))
                  {
                        log.debug("ClientSocketProtocol >> asyncSend >> CLOSE message received from the server");                                    
                        outStream.close();      
                        inStream.close();
                  }
                  
      }
      
      catch (SocketException e)
      {
            log.debug("ClientSocketProtocol >> asyncsend >> Exception occurred while sending the " +
                        "request to NE Manager " + e.getCause() + "\n" + e.getMessage());
            returnCode = NWMErrorCode.GEN_SOCKET_FAILURE;             
      }
      catch (Exception e)
      {
            log.debug("ClientSocketProtocol >> asyncsend >> Exception occurred while sending the " +
                        "request to NE Manager " + e.getCause() + "\n" + e.getMessage());
            
            returnCode = NWMErrorCode.GEN_ERROR;
      }
      finally
      {
            try {      
                  theSocket.close();
                  theSocket = null;                  
              log.debug("ClientSocketProtocol >> asyncSend >> Poll network socket is closed in the client side");      
            } catch (IOException e) {
                  log.debug("ClientSocketProtocol >> asyncsend >> Exception occurred  while closing socket" + e.getCause() + "\n" + e.getMessage());
            }            
      }
      
      return returnCode;
      }

Can you please post code in the snippet window?

Closing the connection is effectively being made contingent on

>>String msg = inStream.readLine();

in asyncSend. It the above line blocks, then nothing is going to get closed. I would 'count them out and count them in'. Generate a sequence number and log.debug that at the outset and log.debug it on close. Fortunately you're implementing logging properly so that should be easy to implement

I already attached a file in my first post itself.  Pl find CLOSE-WAITProblem.txt. Do you need entire file content?