COUNTER now runs on a forkChannel over an already connected main chan…

…nel (https://issues.jboss.org/browse/JGRP-2156)
belaban · Feb 7, 2017 · f8d65f9 · f8d65f9
1 parent e70c99f
commit f8d65f9
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/org/jgroups/protocols/COUNTER.java b/src/org/jgroups/protocols/COUNTER.java
@@ -163,6 +163,9 @@ public Object down(Event evt) {
             case Event.SET_LOCAL_ADDRESS:
                 local_addr=(Address)evt.getArg();
                 break;
+            case Event.VIEW_CHANGE:
+                handleView((View)evt.arg());
+                break;
         }
         return down_prot.down(evt);
     }

diff --git a/tests/junit-functional/org/jgroups/tests/ForkChannelTest.java b/tests/junit-functional/org/jgroups/tests/ForkChannelTest.java
@@ -261,9 +261,10 @@ public void testNullForkStack() throws Exception {
      * @throws Exception
      */
     public void testCounterService() throws Exception {
+        a.connect(CLUSTER);
         fc1=new ForkChannel(a, "stack", "fc1", false,ProtocolStack.ABOVE, FORK.class, new COUNTER());
         fc2=new ForkChannel(a, "stack", "fc2", false,ProtocolStack.ABOVE, FORK.class, new COUNTER());
-        a.connect(CLUSTER);
+
         fc1.connect("foo");
         fc2.connect("bar");