[jboss-cvs] JBoss Messaging SVN: r8395 - branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice.

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

Author: gaohoward
Date: 2011-07-28 07:10:48 -0400 (Thu, 28 Jul 2011)
New Revision: 8395

Modified:
   branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
Log:
JBMESSAGING-1892


Modified: branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
===================================================================
--- branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-07-26 13:12:35 UTC (rev 8394)
+++ branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-07-28 11:10:48 UTC (rev 8395)
@@ -56,6 +56,7 @@
 import org.jboss.jms.server.ServerPeer;
 import org.jboss.jms.server.destination.ManagedDestination;
 import org.jboss.jms.server.endpoint.ServerSessionEndpoint;
+import org.jboss.jms.server.remoting.JMSServerInvocationHandler;
 import org.jboss.logging.Logger;
 import org.jboss.messaging.core.contract.Binding;
 import org.jboss.messaging.core.contract.ChannelFactory;
@@ -4438,6 +4439,13 @@
 
    public void unregisterChannelInJmx(MBeanServer server, String channelPartitionName)
    {
+      if (this.failoverOnNodeLeave)
+      {
+         //JBMESSAGING-1892
+         //this makes sure no more requests coming in after the last one.
+         JMSServerInvocationHandler.setClosed(true);
+      }
+
       groupMember.unregisterChannelInJmx(server, channelPartitionName);
    }