Java socket server running from witin weblogic

[robert sturn]

I have requirement that my java server program to be running from within weblogic server.

I created a java Server program which is created as a thread.This thread is started when weblogic starts.

 
public class SimpleListner {
 
    static final int PORT = 8888;
    private static  ServerSocket serv = null;
    public static void main( String args[] )
    {
       startListner();
    }
 
    public static void reConnect() {
        System.out.println("Reconnecting.....");
        if(!serv.isClosed())
            try {
                serv.close();
            } catch (IOException e) {
                 System.out.println("SimpleListner.reConnect..");
            }
        SimpleListner.startListner();
    }
 
    public static void startListner()
    {
        System.out.println("Entering SimpleListner.startListner().....");
        boolean listning=true;
        try
        {
             serv = new ServerSocket(PORT);
             System.out.println( "SimpleListner ready" );
              while(listning)
             {
                RequestHandler requestHandler = new RequestHandler(serv.accept());
                Thread thread = new Thread(requestHandler);
                thread.start();
                System.out.println( "RequestHandler.start()..." );
             }
           }
        catch (IOException e)
        {
                System.out.println("Simple Listner.IO Exception occured  " + e);
                //Reestablish the connection with peer
                 reConnect();
        }
        System.out.println("Entering SimpleListner.startListner().....");
 
    }//start listner ends
}
 
   

Here is the code for actual request handler

  public class RequestHandler implements Runnable {
 
    Socket socket;
    RequestHandler (Socket socket)
    {
        this.socket=socket;
        CommandUtil.init();
    }
 
    public void handleRequest()
    {
            try {
                System.out.println( "Entering RequestHandler.handleRequest()" );
 

                      Socket sock = this.socket;
                      BufferedReader in = new BufferedReader (new InputStreamReader (sock.getInputStream()) );
                      PrintStream out = new PrintStream(sock.getOutputStream());
                      String fromClient ;
                      boolean keepAdding=false;
                      Message tempMessage = new Message();
                      System.out.println("Begin while loop VVVVVVVVVVVVVVVVVVVVVVVV ");
                      while ((fromClient  = in.readLine()) != null)
                      {
                          System.out.println("In while loop from MLPI --> " + fromClient);
                          //int code = deCodeMessage(fromClient);
                          System.out.println("Adding.."+fromClient +" to Message object");
                          Message message = new  Message();
                          message.addLine(fromClient);
                          //For one liner messages we need to respond after we read one line
                          if(message.isOneLiner() && message.isHeader())
                          {
                             System.out.println("Inside if  if(message.isOneLiner() && message.isHeader())");
                             sendMessage(message,out);
                             keepAdding=false;
                          }
                          else
                          {
                              System.out.println("Inside else");
                              keepAdding=true;
                              tempMessage.addLine(fromClient);
                          }
 
                          if(keepAdding && "###".equals(fromClient))
                          {
                                 System.out.println("This is the end of the message tempMessage="+ tempMessage.toString());
                                 sendMessage(tempMessage,out);
                           }
 
                          System.out.println("Leaving while loop --> " + fromClient);
                          //For multiline messages read until you get ###
                          //Send this message to CommandManager and get the response.
                      } //readLine while true
                    System.out.println("End while loop ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^");
                    out.flush();
                    //System.out.println("Closing out stream opened to write to client...");
                    //out.close();
                    System.out.println("Out stream is closed now ...");
//                 } //socket while true
 
                System.out.println("After finishing while(true) ...");
 

             } catch (IOException e)
             {
                System.out.println("RequestHandler IO Exception occured  " );
                e.printStackTrace();
                //System.out.println("Closing server connection...");
                OnyxMLPIServer.reConnect();
                //Reestablish the connection with peer
                //SimpleListner.startListner();
             } catch (IllegalAccessException e)
            {
                e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
            } catch (ClassNotFoundException e)
            {
                e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
            } catch (InstantiationException e)
            {
                e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
            }
        System.out.println( "Leaving RequestHandler.handleRequest()" );
    }  

sendMessage

 public void sendMessage(Message message,PrintStream out) throws ClassNotFoundException, IllegalAccessException, InstantiationException
    {
              //Get the command for this message
              String commandName = CommandUtil.getCommand(message);
              String fullClassName = "com.ssss.sockets.commands."+commandName;
              System.out.println(fullClassName);
              Command command = (Command)Class.forName(fullClassName).newInstance();
              command.setMessage(message);
              //respond
              CommandManager manager = new CommandManager();
              //Command command = new LoginCommand(new BOFacade(),message);
              manager.setCommand(command);
              //Get the appropriate command
              Message returnMessage = manager.sendCommand();
              System.out.println("returnMessage=>>" + returnMessage +"<<");
              out.println(returnMessage.toString());
    }    

When I run the third party client which talks to ths server program I get socket exception saying connection reset.

If I run this server as an independent program it works fine.
Running from within gives socket exception.

Has anyone faced this problem?I would appreciate your reply since I already spent couple of days on this.

Regards
Robert sk

[robert sturn]

This is the exception i get..

java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:168
at java.io.InputStreamReader.read(InputStreamReader.java:167)
at java.io.BufferedReader.fill(BufferedReader.java:136)
at java.io.BufferedReader.readLine(BufferedReader.java:299)Inside if if(message.isOneLiner() && message.isHeader())
at java.io.BufferedReader.readLine(BufferedReader.java:362)Entering sendMessage
at com.fapd.lpi.mlpi.util.MLPIRequestHandler.handleRequest(MLPIRequestHandler.java:119)
at com.fapd.lpi.mlpi.util.MLPIRequestHandler.run(MLPIRequestHandler.java:190)
at java.lang.Thread.run()V(Unknown Source)