Testing is a crucial part of any development or integration work. In case you're using the Camel CDI integration for your applications, you have a number of options to ease testing.
You can use CDI for IoC and the Camel testing endpoints like DataSet
, Mock
, Test
and testing API like AdviceWith
and NotifyBuilder
to create sophisticated integration/unit tests that are easy to run and debug inside your IDE.
There are a number of supported approaches for testing with CDI in Camel:
Name | Testing Frameworks Supported | Description |
---|---|---|
Camel CDI Test |
| Available as of Camel 2.17 The Camel CDI test module ( |
Arquillian |
| Arquillian is a testing platform that handles all the plumbing of in-container testing with support for a wide range of target containers. Arquillian can be configured to run your test classes in embedded (in JVM CDI), managed (a real Web server or Java EE application server instance started in a separate process) or remote (the lifecycle of the container isn't managed by Arquillian) modes. You have to create the System Under Test (SUT) in your test classes using ShrinkWrap descriptors. The benefit is that you have a very fine-grained control over the application configuration that you want to test. The downside is more code and more complex classpath / class loading structure. |
PAX Exam |
| PAX Exam lets you test your Camel applications in OSGi, Java EE or standalone CDI containers with the ability to finely configure your System Under Test (SUT), similarly to Arquillian. You can use it to test your Camel CDI applications that target OSGi environments like Karaf with PAX CDI, but you can use it as well to test your Camel CDI applications in standalone CDI containers, Web containers and Java EE containers. |
Camel CDI Test
With this approach, your test classes use the JUnit runner provided in Camel CDI test. This runner manages the lifecycle of a standalone CDI container and automatically assemble and deploy the System Under Test (SUT) based on the classpath into the container.
It deploys the test class as a CDI bean so that dependency injection and any CDI features is available within the test class.
Maven users will need to add the following dependency to their pom.xml
for this component:
<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-test-cdi</artifactId> <scope>test</test> <version>x.x.x</version> <!-- use the same version as your Camel core version --> </dependency>
Here is a simple unit test using the CamelCdiRunner
:
@RunWith(CamelCdiRunner.class) public class CamelCdiRunnerTest { @Inject CamelContext context; @Test public void test() { assertThat("Camel context status is incorrect!", context.getStatus(), is(equalTo(ServiceStatus.Started))); } }
CDI injection is also available for test method parameters, e.g.:
@RunWith(CamelCdiRunner.class) public class CamelCdiRunnerTest { @Test public void test(@Uri("direct:foo") ProducerTemplate producer) { producer.sendBody("bar"); } }
Camel CDI test provides the @Order
annotation that you can use to execute the test methods in a particular sequence, e.g.:
@RunWith(CamelCdiRunner.class) public class CamelCdiRunnerTest { @Test @Order(1) public void firstTestMethod() { } @Test @Order(2) public void secondTestMethod() { } }
One CDI container is bootstrapped for the entire execution of the test class.
Besides, the test class is deployed as a CDI bean, so that you can control how the runner instantiate the test class, either one test class instance for each test method (the default, depending on the built-in default @Dependent
CDI scope), or one test class instance for the entire test class execution using the @ApplicationScoped
scope, e.g.:
@ApplicationScoped @RunWith(CamelCdiRunner.class) public class CamelCdiRunnerTest { int counter; @Test @Order(1) public void firstTestMethod() { counter++; } @Test @Order(2) public void secondTestMethod() { assertEquals(counter, 1); } }
Arquillian
With this approach, you use the JUnit runner or TestNG support provided by Arquillian to delegate the bootstrap of the CDI container. You need to declare a @Deployment
method to create your application configuration to be deployed in the container using ShrinkWrap descriptors, e.g.:
@RunWith(Arquillian.class) public class CamelCdiJavaSeTest { @Deployment public static Archive deployment() { return ShrinkWrap.create(JavaArchive.class) // Camel CDI .addPackage(CdiCamelExtension.class.getPackage()) // Test classes .addPackage(Application.class.getPackage()) // Bean archive deployment descriptor .addAsManifestResource(EmptyAsset.INSTANCE, "beans.xml"); } @Inject CamelContext context; @Test public void test() { assertThat("Camel context status is incorrect!", context.getStatus(), is(equalTo(ServiceStatus.Started))); } }
In that example, you can use any Java SE Arquillian embedded container adapter, like the Weld embedded container adapter e.g. with Maven you need that complete set of dependencies:
<dependencies> <dependency> <groupId>org.jboss.arquillian.junit</groupId> <artifactId>arquillian-junit-container</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.shrinkwrap.descriptors</groupId> <artifactId>shrinkwrap-descriptors-depchain</artifactId> <type>pom</type> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.arquillian.container</groupId> <artifactId>arquillian-weld-se-embedded-1.1</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.weld</groupId> <artifactId>weld-core</artifactId> <scope>test</scope> </dependency> </dependencies>
Using ShrinkWarp Descriptors, you have a complete control over the configuration and kind of Camel CDI applications you want to test. For example, to test a Camel CDI application that uses the Camel REST DSL configured with the Servlet component, you need to create a Web archive, e.g.:
@RunWith(Arquillian.class) public class CamelCdiWebTest { @Deployment public static Archive<?> createTestArchive() { return ShrinkWrap.create(WebArchive.class) .addClass(Application.class) .addAsWebInfResource(EmptyAsset.INSTANCE, ArchivePaths.create("beans.xml")) .setWebXML(Paths.get("src/main/webapp/WEB-INF/web.xml").toFile()); } @Test @RunAsClient public void test(@ArquillianResource URL url) throws Exception { assertThat(IOHelper.loadText(new URL(url, "camel/rest/hello").openStream()), is(equalTo("Hello World!\n"))); } }
In the example above, you can use any Arquillian Web container adapter, like the Jetty embedded container adapter e.g. with Maven you need the complete following set of dependencies:
</dependencies> <dependency> <groupId>org.jboss.arquillian.junit</groupId> <artifactId>arquillian-junit-container</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.arquillian.testenricher</groupId> <artifactId>arquillian-testenricher-resource</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.shrinkwrap.descriptors</groupId> <artifactId>shrinkwrap-descriptors-depchain</artifactId> <type>pom</type> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.weld.servlet</groupId> <artifactId>weld-servlet</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.eclipse.jetty</groupId> <artifactId>jetty-webapp</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.eclipse.jetty</groupId> <artifactId>jetty-annotations</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.jboss.arquillian.container</groupId> <artifactId>arquillian-jetty-embedded-9</artifactId> <scope>test</scope> </dependency> </dependencies>
You can see the tests in the camel-example-cdi-rest-servlet
example for a complete working example of testing a Camel CDI application using the REST DSL and deployed as a WAR in Jetty.
PAX Exam
If you target OSGi as runtime environment for your Camel CDI applications, you can use PAX Exam to automate the deployment of your tests into an OSGi container, for example into Karaf, e.g.:
@RunWith(PaxExam.class) @ExamReactorStrategy(PerClass.class) public class PaxCdiOsgiTest { @Configuration public Option[] config() throws IOException { return options( // Karaf configuration karafDistributionConfiguration() .frameworkUrl( maven() .groupId("org.apache.karaf") .artifactId("apache-karaf") .versionAsInProject() .type("zip")) .name("Apache Karaf") .unpackDirectory(new File("target/paxexam/unpack/")), // PAX CDI Weld features( maven() .groupId("org.ops4j.pax.cdi") .artifactId("pax-cdi-features") .type("xml") .classifier("features") .versionAsInProject(), "pax-cdi-weld"), // Karaf Camel commands mavenBundle() .groupId("your.application.groupId") .artifactId("your.application.artifactId") .versionAsInProject() ); } @Inject private CamelContext context; @Test public void testContextStatus() { assertThat("Camel context status is incorrect!", context.getStatus(), equalTo(ServiceStatus.Started)); } }
You can see the tests in the camel-example-cdi-osgi
example for a complete working example of testing a Camel CDI application deployed in an OSGi container using PAX Exam.
Testing Patterns
You can see the tests in the camel-example-cdi-test
example for a thorough overview of the following testing patterns for Camel CDI applications.
Routes advising with adviceWith
AdviceWith
is used for testing Camel routes where you can advice an existing route before its being tested. It allows to add Intercept or weave routes for testing purpose, for example using the Mock component.
It is recommended to only advice routes which are not started already. To meet that requirement, you can use the CamelContextStartingEvent
event by declaring an observer method in which you use adviceWith
to add a mock
endpoint at the end of your Camel route, e.g.:
void advice(@Observes CamelContextStartingEvent event, @Uri("mock:test") MockEndpoint messages, ModelCamelContext context) throws Exception { context.getRouteDefinition("route") .adviceWith(context, new AdviceWithRouteBuilder() { @Override public void configure() { weaveAddLast().to("mock:test"); } }); }
Bean alternatives
Test routes
Camel context customisation
You may need to customise your Camel contexts for testing purpose, for example disabling JMX management to avoid TCP port allocation conflict. You can do that by declaring a custom Camel context bean in your test class, e.g.:
@RunWith(CamelCdiRunner.class) public class CamelCdiTest { @Default @ContextName("camel-test-cdi") @ApplicationScoped static class CustomCamelContext extends DefaultCamelContext { @PostConstruct void customize() { disableJMX(); } } }
In that example, the custom Camel context bean declared in the test class will be used during the test execution instead of the default Camel context bean provided by the Camel CDI component.
JUnit rules
Camel CDI test starts the CDI container after all the JUnit class rules have executed.
That way, you can use JUnit class rules to initialise (resp. clean-up) resources that your test classes would require during their execution before the container initialises (resp. after the container has shutdown). For example, you could use an embedded JMS broker like ActiveMQ Artemis to test your Camel JMS application, e.g.:
import org.apache.activemq.artemis.jms.server.embedded.EmbeddedJMS; @RunWith(CamelCdiRunner.class) public class CamelCdiTest { @ClassRule public static final ExternalResource resources = new ExternalResource() { private final EmbeddedJMS jms = new EmbeddedJMS(); @Override protected void before() throws Exception { jms.start(); } @Override protected void after() throws Exception { jms.stop(); } }; @Inject @Uri("jms:destination") private ProducerTemplate producer; @Test public void sendMessage() { producer.sendBody("message"); } }
Another use case is to assert the behaviour of your application after it has shutdown. In that case, you can use the Verifier
rule, e.g.:
import org.junit.rules.Verifier; @RunWith(CamelCdiRunner.class) public class CamelCdiTest { @ClassRule public static Verifier verifier = new Verifier() { @Override protected void verify() { // Executes after the CDI container has shutdown } }; }