My application need to be amended

My application is passing a short message through the socket connection and it should be read back on the client side. I have tested the application and currently only server side is reading the message. I do not know how to change a client so it can read the message too.

I am passing a serialized object from client to a server. on the server side I am using ArrayList to store the object access it and read it out. I think I need to change client accordingly so it can understand that the object to be read is element of the ArrayList. I think the class AccountInfo has to be amended too. Would you please advice.

This is my classes: AccountInfo, AccountClient, AccountServer

import java.io.Serializable;



public class AccountInfo implements Serializable {
      static String TimeStamp;
      private int amount = 100;
      private String message = "1ZA";
      
   /**
      *
      */
     private static final long serialVersionUID = 1L;


   public AccountInfo(int amount,String message) {
      this.amount = amount;
      this.message = message;
   }
   
   public AccountInfo() {
      // TODO Auto-generated constructor stub
}

public void setAmount(int amount){
        this.amount = amount;
   }
   
   public int getAmount() {
          return 0;
     }
   public void setMessage(String message){
         this.message = message;
   }
   public String getMessage(){
         return message;
   }
   
   

   public void printInfo() {
         TimeStamp = new java.util.Date().toString();
         System.out.println("\n" +TimeStamp + " Transfer no " +message+ " \nTransfering £"+ amount +" from account A to account B \n<<Transferr Done!>>" );
        
   }


}

------------------------------------------------------------------

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.ArrayList;

public class AccountClient implements Runnable {

     private static long DELAY = 2000; // 2 second delay between retries
     private static ObjectInputStream ois;
     private static ObjectOutputStream oos;

     private boolean haveReadServerAcknowledgement;

     private boolean haveConnected;
     
     private boolean haveConnectedSatisfactorily;
     
      

     public static void main(String argv[]) throws IOException,
               ClassNotFoundException {
          System.setProperty("sun.net.client.defaultReadTimeout", "5000"); // Five second acknowledgement window
         
          AccountClient client = new AccountClient();
          new Thread(client).start();
         
     }

     void connectClient() throws IOException {
          int counter = 1;

          do {
               try {
                    
                    Socket socket = new Socket("192.168.0.4", 4000);
                    haveConnected = socket.isConnected();
                     try {
                         
                       
                          
                          oos = new ObjectOutputStream(socket.getOutputStream());
                        ois = new ObjectInputStream(socket.getInputStream());
                        //socket.setSoTimeout(1000);
                                    
                                    // create serialized object
                        AccountInfo user1 = new AccountInfo();
                       
                        // write the objects to the server
                        oos.writeObject(user1);
                        oos.flush();
                       
                        // read an object from the server
                        user1 = (AccountInfo) ois.readObject();
                        user1.printInfo();
                       
                        oos.close();
                        ois.close();
                    } catch (IOException e) {
                          int x = 1;
                          while(x <5){
                                Thread.sleep(DELAY);
                                System.out.println("Attempt: " + x +
                                      "\t Re-sending Request To the Server");
                                if(x <4){
                                      Thread.sleep(DELAY);
                                      System.err.println("Trying again in " + DELAY + " milliseconds.........");
                                }else
                                      System.err.println("giving up");
                                x++;
                                
                          }
                          continue;
                    }
                    try{
                          Thread.sleep(DELAY);
                    }catch(InterruptedException ex){
                          /*ingore*/
                          continue;
                    }
                    haveReadServerAcknowledgement = true;
                    haveConnectedSatisfactorily = (haveReadServerAcknowledgement && haveConnected);
               } catch (Exception e) {
                    System.out.println(e.getMessage());
                    System.err.println("Cannot connect. Trying again in " + DELAY + " milliseconds");
                   
                   
                    try {
                         Thread.sleep(DELAY);
                    } catch (InterruptedException ex) {
                         /* ignore */
                    }
               }
               counter++;
          } while (haveConnectedSatisfactorily == false && counter <= 4);

          if (counter > 4) {
               System.err.println("Failed to connect. Giving up");

          }
         
     }

     public void run() {
          try {
               connectClient();
               createClientLog();
          } catch (IOException e) {
               e.printStackTrace();
          }

     }
     
     

            public void createClientLog() {
                  // TODO Auto-generated method stub
                  try {
                        ObjectOutputStream oos = new ObjectOutputStream(new
                                    FileOutputStream("C:\\Logs\\ClientLogs\\Already_Processed.txt"));
                        AccountInfo user1 = new AccountInfo();
                        oos.writeObject(user1);
                oos.flush();
                oos.close();

                  } catch (FileNotFoundException e) {
                        e.printStackTrace();
                  } catch (IOException e) {
                        e.printStackTrace();
                  }

                  
            }
     }


-----------------------------------------------------------------------

import java.io.*;
import java.net.*;
//import java.nio.channels.FileChannel;
import java.util.ArrayList;




public class AccountServer extends Thread {
       private static long DELAY = 2000;
       private ServerSocket dateServer;
      

     /**
      * @param args
      */
     public static void main(String[] args) throws Exception {
           new AccountServer();
     }
     
     public AccountServer() throws Exception {
          
           dateServer = new ServerSocket(4000);
         System.out.println("--------------------------------------------------");
         Thread.sleep(DELAY);
         System.out.println("Server is starting ......... \n");
         Thread.sleep(DELAY);
         System.out.print("Server listening on port 4000...");
         this.start();
     }
     
     public void run() {
          
           while(true) {
                 
                 try{
                      
                       Thread.sleep(DELAY);
                   System.out.println("\nWaiting for new connections ...\n");
                 System.out.println("--------------------------------------------------");
                 Socket client = dateServer.accept();
                 System.out.println("Accepted a connection from: "+
                             client.getInetAddress()+ "");
                 Thread.sleep(DELAY);
                 System.out.print("\nSending acknowledgement....\n");
                 Connect c = new Connect(client);
             }catch(Exception e){}
           }
         }
 }


class Connect extends Thread {
    private Socket client = null;
    private ObjectInputStream ois = null;
    private ObjectOutputStream oos = null;
   
    public Connect() {}

    public Connect(Socket clientSocket) {
          client = clientSocket;
          try{
                
                ois = new ObjectInputStream(client.getInputStream());
            oos = new ObjectOutputStream(client.getOutputStream());
            //Thread.sleep(150000);
          }catch(Exception e1){
                try{
                      client.close();
                }catch(Exception e){
                      System.out.println(e.getMessage());
                      
                }
                return;
          }
          this.start();
    }
   
    public void run(){
          
          try{
                
                AccountInfo user1 = ( AccountInfo ) ois.readObject () ;
                
                //save request to file called ReceivedLog
                ObjectOutputStream oos = new ObjectOutputStream(new
               FileOutputStream("C:\\Logs\\ReceivedServerLog\\To_Be_Processed.txt"));          
             ArrayList list = new ArrayList();
             list.add(user1);
             oos.writeObject(list);                              
             oos.flush();
             oos.close();
                       
                       
            ObjectInputStream ois = new ObjectInputStream(new
               FileInputStream("C:\\Logs\\ReceivedServerLog\\To_Be_Processed.txt"));
            list = ( ArrayList ) ois.readObject () ;
            ois.close () ;
            AccountInfo info = ( AccountInfo ) list.get ( 0 ) ; // get the  object to be processed
           
                  info.printInfo(); // process it
           
           
            oos = new ObjectOutputStream(new
              FileOutputStream("C:\\Logs\\ProcessedServerLog\\Already_Processed.txt"));
            ArrayList list1 = new ArrayList();
            list1.add ( info ) ; // add the processed request to ProcessedLog
            oos.writeObject ( list1 ) ;
            oos.flush () ;
            oos.close () ;
                       
            oos = new ObjectOutputStream(new
               FileOutputStream("C:\\Logs\\ReceivedServerLog\\To_Be_Processed.txt"));
            list.remove(0);//remove request
            oos.writeObject(list); // overite the receivedLog - minus the processed request
            oos.flush();
            oos.close();
                                                                                         
                       
                       
           
          }
          catch(IOException ex){
                ex.printStackTrace();
          }catch(ClassNotFoundException e){
          }
    }
 }