[jboss-cvs] JBoss Messaging SVN: r5282 - trunk/src/main/org/jboss/messaging/core/server/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2008-11-05 15:46:41 -0500 (Wed, 05 Nov 2008)
New Revision: 5282

Modified:
   trunk/src/main/org/jboss/messaging/core/server/impl/ServerSessionImpl.java
Log:
Replicate session close on connection failure


Modified: trunk/src/main/org/jboss/messaging/core/server/impl/ServerSessionImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/server/impl/ServerSessionImpl.java	2008-11-05 19:02:14 UTC (rev 5281)
+++ trunk/src/main/org/jboss/messaging/core/server/impl/ServerSessionImpl.java	2008-11-05 20:46:41 UTC (rev 5282)
@@ -47,6 +47,7 @@
 import org.jboss.messaging.core.remoting.impl.ByteBufferWrapper;
 import org.jboss.messaging.core.remoting.impl.wireformat.MessagingExceptionMessage;
 import org.jboss.messaging.core.remoting.impl.wireformat.NullResponseMessage;
+import org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl;
 import org.jboss.messaging.core.remoting.impl.wireformat.SessionAcknowledgeMessage;
 import org.jboss.messaging.core.remoting.impl.wireformat.SessionAddDestinationMessage;
 import org.jboss.messaging.core.remoting.impl.wireformat.SessionBindingQueryMessage;
@@ -2110,6 +2111,8 @@
       }
 
       channel.send(response);
+      
+      channel.close();
    }
 
    private void setStarted(final boolean s)
@@ -2557,9 +2560,8 @@
             }
          }
 
-         close();
-
-         channel.close();
+         //We call handleClose() since we need to replicate the close too, if there is a backup
+         handleClose(new PacketImpl(PacketImpl.SESS_CLOSE));
       }
       catch (Throwable t)
       {