Unit testing a route with a from activemq

[garethahealy]

I am trying to unit test a route - i am using blueprints - which uses active mq (see below)

I then have this in my java code:

protected CamelContext createCamelContext() throws Exception {

    CamelContext camelContext = super.createCamelContext();

    camelContext.addComponent("activemq", ActiveMQComponent.activeMQComponent("vm://localhost?broker.persistent=false"));

    return camelContext;

}

But when i try to run the test, it times out and fails with the following:

java.lang.RuntimeException: Gave up waiting for service (objectClass=org.apache.camel.CamelContext)

     at com.boohoo.blueprint.test.CamelBlueprintHelper.getOsgiService(CamelBlueprintHelper.java:170)

     at com.boohoo.blueprint.test.CamelBlueprintHelper.getOsgiService(CamelBlueprintHelper.java:130)

     at com.boohoo.blueprint.test.CamelBlueprintTestSupport.createCamelContext(CamelBlueprintTestSupport.java:90)

     at com.boohoo.esb.common.tests.route.Test_Route_loggingWithObject.createCamelContext(Test_Route_loggingWithObject.java:30)

     at org.apache.camel.test.junit4.CamelTestSupport.doSetUp(CamelTestSupport.java:234)

     at org.apache.camel.test.junit4.CamelTestSupport.setUp(CamelTestSupport.java:204)

     at com.boohoo.blueprint.test.CamelBlueprintTestSupport.setUp(CamelBlueprintTestSupport.java:40)

     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)

     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)

     at java.lang.reflect.Method.invoke(Method.java:597)

     at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)

     at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)

     at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)

     at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:27)

     at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:30)

     at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:47)

     at org.junit.rules.RunRules.evaluate(RunRules.java:18)

     at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:263)

     at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:68)

     at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:47)

     at org.junit.runners.ParentRunner$3.run(ParentRunner.java:231)

     at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:60)

     at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:229)

     at org.junit.runners.ParentRunner.access$000(ParentRunner.java:50)

     at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:222)

     at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:30)

     at org.junit.runners.ParentRunner.run(ParentRunner.java:300)

     at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:249)

     at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:142)

     at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:113)

     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)

     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)

     at java.lang.reflect.Method.invoke(Method.java:597)

     at org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)

     at org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)

     at org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)

     at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:104)

     at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)

Is what i am doing possible? because i think it is. I am wanting to "mock" the activemq component so i dont have to change the xml file to be a direct.

Hope the above makes sense.

Cheers.

Edited by: garethahealy on Aug 23, 2012 11:17 AM

[davsclaus]

How do you run the unit test? Using camel-test-blueprint?

And you got all the ActiveMQ JARs on the classpath. And what version of Camel and AMQ are you using?

[garethahealy]

I have the following dependencies for active mq:

(camel = 2.9.0)

(activemq-version = 5.5.1)

As i am using camel 2.9, i am not yet using the full camel-test-blueprint, but a cut down version, which a consultant (he was from fuse) gave us, which i believe to be pretty much the same.

The unit tests are using JUnit (4.10) and the maven surefire plugin.

[davsclaus]

Check the logs there may be a indication what is wrong.

[garethahealy]

I've had a look in the logs but cannot see any errors / anything obvious. There are a few warnings to do with not being able to get components, but i dont think they are related. I've created a simple example which shows what i am doing.

[davsclaus]

The Fuse Camel releases 2.9 and 2.8 both have the camel-test-blueprint component out of the box.

[davsclaus]

For example here

http://repo.fusesource.com/nexus/content/groups/public/org/apache/camel/camel-test-blueprint/2.9.0.fuse-7-061/

[davsclaus]

Okay I got your example working.

You have to define the activemq component in a blueprint xml file, to have it properly intitalized. So I created a new file myactivemq.xml

<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
       
     <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
          <property name="brokerURL" value="vm://localhost?broker.persistent=false"></property>
     </bean>

</blueprint>

And then from the unit tests I refer to 2 xml files to load. Notice the addition of the myactivemq.xml file, separated by comma

     @Override
    protected String getBlueprintDescriptor() {
        return "myactivemq.xml,boohoo-esb-common-context.xml";
    }

And then I removed the overridden createCamelContext method you did.

[garethahealy]

Claus,

I've made the changes you suggested and it works now. I've also changed over to the real test-blueprints bundle as you suggested.

Thanks!

[garethahealy]

PS. If i wanted to get a BundleContext back, would i need to use pax-exam for this? or is there a way with the testing bundles? (test-blueprint and test)

Edited by: garethahealy on Aug 29, 2012 10:07 AM

[davsclaus]

There is a method for that. It may have been added since those releases, but it will then be included in upcoming releases

  /**
     * Return the system bundle context
     */
    protected BundleContext getBundleContext() {
        return bundleContext;
    }

Its in the test support class.

[garethahealy]

Yeah, google told me to use that method as well, but sadly its not in the that release. Cheers anyways.