onMessage method of websocket client endpoint stopping after message received

[Colm Dickson]

Hi all.

I have a websocket java client connecting to a server to read back the messages from that server. The onMessage method does appear to be obtaining the messages from the server but I noticed an issue when I added further code within the same method. In my case I wanted to log the messages to a database but noticed the database code was not being executed. I removed the database code and put in some println debug and found out that they were not always being executed or that some were but others were not.I also added a for loop which too should complete but stops before the end at differing points, I have the onError and onClose methods implemented and they are not being fired by any error or socket closure. I have included the client code below. Has anyone else encountered this? I'm running jdk 7 and I'm really puzzled by this.
thanks.

import java.net.URI;

import java.io.IOException;

import java.util.logging.Level;

import java.util.logging.Logger;

import javax.websocket.Endpoint;

import javax.websocket.EndpointConfig;

import javax.websocket.MessageHandler;

import javax.websocket.Session;

import javax.websocket.CloseReason;

import java.sql.*;



 

public class ClientSocketEndpoint extends Endpoint 

{

    

    private Session session;

    private String returnMessage = "WAITING";

    private String receivedMessage = "";

  


    

    @Override

    public void onOpen(Session session, EndpointConfig endpointConfig) 

    {

        

        this.session = session;

        

        this.session.addMessageHandler(new MessageHandler.Whole<String>()

                 {

                    @Override

                      public void onMessage(String message) 

                      {


                                         System.out.println("retrieved " + message);
                                     
                                         

                                         for (int i=0; i<20; i++) 

                                         {

                                             System.out.println("looping value = "+ i);


                                         }

                                         

                                         System.out.println("1");

                                         System.out.println("2");

                                         System.out.println("3");

                                         System.out.println("4");

                                         System.out.println("5");

                                         System.out.println("6");

                                         System.out.println("7");

                                         System.out.println("8");

                                         System.out.println("9");

                                         System.out.println("10");

                                         System.out.println("11");

                                         System.out.println("12");

                                         System.out.println("13");

                                         System.out.println("15");

                                         System.out.println("15");

                                         System.out.println("16");

                                          

                                          

                                      

                                        
                                         

                                         

                                      
                                                  

                                      

                                      }

  

                        }   

 

                   

                  }

                  

                  

                   

               

    }// end of onOpen method

    

            public void sendMessage(String message) throws IOException

            {

                this.session.getBasicRemote().sendText(message);

            }

            

            @Override

            public void onError(Session session,Throwable thr)

            {

 

                System.out.println("onMessageerror");    

                this.returnMessage = "ERROR";

                

            }

            

            @Override

            public void onClose(Session session,CloseReason closeReason)

            {

                System.out.println("client socket closed by server");          

            }

           
    

    

    }