[servicemix-scm] Created ClusterFlow from receiver container. This is used to assert true that the cluster has been completed.

[foconer]

Commit in servicemix/base/src/test/java/org/servicemix/jbi/nmr/flow/cluster on MAIN
ClusterFlowTest.java	+5	-5	1.5 -> 1.6

Created ClusterFlow from receiver container. This is used to assert true that the cluster has been completed.

---

servicemix/base/src/test/java/org/servicemix/jbi/nmr/flow/cluster

ClusterFlowTest.java 1.5 -> 1.6

diff -u -r1.5 -r1.6
--- ClusterFlowTest.java	20 Jul 2005 13:01:04 -0000	1.5
+++ ClusterFlowTest.java	9 Aug 2005 03:22:45 -0000	1.6
@@ -54,17 +54,17 @@

         receiverContainer.setFlowName("cluster");
         receiverContainer.init();
         receiverContainer.start();

-        

+        ClusterFlow receiverFlow = (ClusterFlow)receiverContainer.getFlow();
+

         receiver = new ReceiverComponent();
         sender = new SenderComponent();
         sender.setResolver(new ServiceNameEndpointResolver(ReceiverComponent.SERVICE));
 
         senderContainer.activateComponent(new ActivationSpec("sender", sender));
         receiverContainer.activateComponent(new ActivationSpec("receiver", receiver));

-        
-        assertTrue("Cluster complete",senderFlow.waitForClusterToComplete(1, 10000));
-       
-       

+
+        assertTrue("Sender cluster complete",senderFlow.waitForClusterToComplete(1, 10000));
+        assertTrue("Receiver cluster complete",receiverFlow.waitForClusterToComplete(1,10000));

     }
     
     protected void tearDown() throws Exception{

CVSspam 0.2.8