[jboss-cvs] JBoss Messaging SVN: r8414 - branches/Branch_JBossMessaging_1_4_8_SP1_JBMESSAGING-1885_JBMESSAGING-1887_JBMESSAGING-1889_JBMESSAGING-1891_JBMESSAGING-1892_JBMESSAGING-1893_JBMESSAGING-1894/src/main/org/jboss/messaging/core/impl/postoffice.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri Aug 12 16:05:38 EDT 2011
Author: raggz
Date: 2011-08-12 16:05:37 -0400 (Fri, 12 Aug 2011)
New Revision: 8414
Modified:
branches/Branch_JBossMessaging_1_4_8_SP1_JBMESSAGING-1885_JBMESSAGING-1887_JBMESSAGING-1889_JBMESSAGING-1891_JBMESSAGING-1892_JBMESSAGING-1893_JBMESSAGING-1894/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
Log:
JBPAPP-7009
Modified: branches/Branch_JBossMessaging_1_4_8_SP1_JBMESSAGING-1885_JBMESSAGING-1887_JBMESSAGING-1889_JBMESSAGING-1891_JBMESSAGING-1892_JBMESSAGING-1893_JBMESSAGING-1894/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
===================================================================
--- branches/Branch_JBossMessaging_1_4_8_SP1_JBMESSAGING-1885_JBMESSAGING-1887_JBMESSAGING-1889_JBMESSAGING-1891_JBMESSAGING-1892_JBMESSAGING-1893_JBMESSAGING-1894/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java 2011-08-12 20:03:09 UTC (rev 8413)
+++ branches/Branch_JBossMessaging_1_4_8_SP1_JBMESSAGING-1885_JBMESSAGING-1887_JBMESSAGING-1889_JBMESSAGING-1891_JBMESSAGING-1892_JBMESSAGING-1893_JBMESSAGING-1894/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java 2011-08-12 20:05:37 UTC (rev 8414)
@@ -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);
}
More information about the jboss-cvs-commits
mailing list