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

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

Author: gaohoward
Date: 2010-09-13 23:24:18 -0400 (Mon, 13 Sep 2010)
New Revision: 8083

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


Modified: branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
===================================================================
--- branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2010-08-24 15:27:41 UTC (rev 8082)
+++ branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2010-09-14 03:24:18 UTC (rev 8083)
@@ -128,6 +128,8 @@
       // We don't want to receive local messages on any of the channels
       controlChannel.setOpt(Channel.LOCAL, Boolean.FALSE);
       
+      controlChannel.setOpt(Channel.AUTO_RECONNECT, Boolean.TRUE);
+      
       MessageListener messageListener = new ControlMessageListener();
       
       MembershipListener membershipListener = new ControlMembershipListener();
@@ -191,6 +193,7 @@
          {
             dataChannel = jChannelFactory.createDataChannel();
             dataChannel.setOpt(Channel.LOCAL, Boolean.FALSE);
+            dataChannel.setOpt(Channel.AUTO_RECONNECT, Boolean.TRUE);
             Receiver dataReceiver = new DataReceiver();
             dataChannel.setReceiver(dataReceiver);
             dataChannel.connect(groupName + DATA_SUFFIX);