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

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

Author: gaohoward
Date: 2011-01-06 09:53:25 -0500 (Thu, 06 Jan 2011)
New Revision: 8162

Modified:
   branches/RIM_patch/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
Log:
port 1819


Modified: branches/RIM_patch/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
===================================================================
--- branches/RIM_patch/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2011-01-04 06:30:50 UTC (rev 8161)
+++ branches/RIM_patch/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2011-01-06 14:53:25 UTC (rev 8162)
@@ -127,6 +127,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();
       
@@ -197,6 +199,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);