Examples of ReattachSessionResponseMessage


Examples of org.hornetq.core.protocol.core.impl.wireformat.ReattachSessionResponseMessage

      try
      {
  
         if (!server.isStarted())
         {
            response = new ReattachSessionResponseMessage(-1, false);
         }
  
         ServerSessionPacketHandler sessionHandler = protocolManager.getSessionHandler(request.getName());
        
         if (!server.checkActivate())
         {
            response = new ReattachSessionResponseMessage(-1, false);
         }
  
         if (sessionHandler == null)
         {
            response = new ReattachSessionResponseMessage(-1, false);
         }
         else
         {
            if (sessionHandler.getChannel().getConfirmationWindowSize() == -1)
            {
               // Even though session exists, we can't reattach since confi window size == -1,
               // i.e. we don't have a resend cache for commands, so we just close the old session
               // and let the client recreate
  
               sessionHandler.close();
  
               response = new ReattachSessionResponseMessage(-1, false);
            }
            else
            {
               // Reconnect the channel to the new connection
               int serverLastConfirmedCommandID = sessionHandler.transferConnection(connection,
                                                                                    request.getLastConfirmedCommandID());
  
               response = new ReattachSessionResponseMessage(serverLastConfirmedCommandID, true);
            }
         }
      }
      catch (Exception e)
      {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.