public void startApp () 
{  
//....
while (1 > 0)
{
  try
  {
    if (clientTCP == null)
    {
      clientTCP = new ClientThread();
      clientTCP.Exchange_Buffer = Exchange_Buffer;
      clientTCP.start();
    }
            
  }
  catch (Exception e)
  {
    System.out.println("Error thread");   
  }
            
  if (clientTCP != null)
  {          
     //???? 
  }
}
///...
  

public void run(){                    //   (class ClientThread extends Thread)
        try 
        {

            sleep(10000);

            sc = (SocketConnection) Connector.open("socket://...;bearer_type=gprs;access_point=static.beeline.ru;username=beeline;password=beeline;timeout=5", Connector.READ_WRITE, true);

            inC = sc.openDataInputStream();
            outC = sc.openDataOutputStream();

            
            //  System.out.println ("remote " + sc.getAddress());
            //  System.out.println ("local " + sc.getLocalAddress());
         }    
         catch (Exception ex) {
             System.out.println ("Error create");
         }
         
         try
         {
             while (1 > 0)
             {    
                    readwriteTCP();
             }
         }
           catch (Exception ex3) {
            System.out.println ("Error readwrite");

           }
        
        
         try
           {
           inC.close();
           outC.close();
           sc.close();
           sc = null;  
           }
            catch (Exception ex2) {
         }

}
}

 public void readwriteTCP() throws InterruptedException, IOException   //(class ClientThread extends Thread)
            
    {
        Command_TCP = 0;
        
        if (inC.available() > 0) 
        {
           Command_TCP = inC.readInt();
        } 
        
        Send_Buffer = "beg:" + Exchange_Buffer + ":end";     
        
        if ((Command_TCP & 0x1) == 1)
        {
            outC.write(Send_Buffer.getBytes());
            outC.flush();
         }             

    }