If you haven't resolved this, could you please post your pom.xml for this
test project?
On Feb 7, 2008 5:46 AM, Sherene <[EMAIL PROTECTED]> wrote:
>
> hi
>
> i want 2 or 3 methods to be executed in parallel. so i have used the
> parallel annotations to each method as below
>
> package com.cts.ParallelPOC.ParalleExample;
>
> import org.apache.commons.logging.Log;
> import org.apache.commons.logging.LogFactory;
> import org.apache.servicemix.beanflow.annotations.Parallel;
> import java.util.concurrent.CountDownLatch;
>
> public class ExampleService{
> private static final Log log = LogFactory.getLog(ExampleService.class);
>
> private CountDownLatch latch = new CountDownLatch(3);
>
> public void shouldNotBeRun() {
> throw new RuntimeException("Should not be ran");
> }
>
> @Parallel
> public void methodOne() {
> log.info("Called method one");
> latch.countDown();
> log.info("method one complete");
>
> }
>
> @Parallel
> public void methodTwo() {
> log.info("Called method two");
> latch.countDown();
> log.info("method two complete");
> }
>
> @Parallel
> public void methodThree() {
> log.info("Called method three");
> latch.countDown();
> log.info("method three complete");
> }
>
>
> }
>
> And i have used the parallelactivity to execute the methods as below
>
> package com.cts.ParallelPOC.ParalleExample;
>
> import org.apache.servicemix.beanflow.ParallelActivity;
> import org.apache.servicemix.beanflow.util.ActivityTestSupport;
> import java.util.concurrent.Executor;
> import java.util.concurrent.Executors;
> import java.util.concurrent.TimeUnit;
> public class Parallelactivitytest extends ActivityTestSupport
> {
>
> protected Executor executor = Executors.newFixedThreadPool(10);
>
> @SuppressWarnings("unchecked")
> public void testParallelWorkflow() throws Exception {
>
> // START SNIPPET: example
> ExampleService parallelBean = new ExampleService();
> ParallelActivity activity =
> ParallelActivity.newParallelMethodActivity(executor, parallelBean);
> activity.startWithTimeout(timer, 2000);
> // END SNIPPET: example
>
> activity.join(10, TimeUnit.SECONDS);
> assertStopped(activity);
> }
> }
> When i deploy i am getiing the following error
> Caused by: java.lang.NoClassDefFoundError:
> org/apache/servicemix/beanflow/ParallelActivity
> at
>
> com.cts.ParallelPOC.ParalleExample.Parallelactivitytest.testParallelWorkflow
> (Para
> llelactivitytest.java:32)
>
> Note: i have included the servicemix-beanflow.jar
> --
> View this message in context:
> http://www.nabble.com/Facing-issue-in-ParallelActivity-class-tp15333098s12049p15333098.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>
>
