ルートの単体テスト

${body} contains 'bar'

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>org.talend</groupId>
    <artifactId>route-unit-test</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.8.1</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-test</artifactId>
            <version>2.9.1</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-jdk14</artifactId>
            <version>1.6.1</version>
        </dependency>
        <dependency>
            <groupId>org.talend.camel</groupId>
            <artifactId>systemRoutines</artifactId>
            <version>1.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.talend.camel</groupId>
            <artifactId>userRoutines</artifactId>
            <version>1.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>SimpleRoute</artifactId>
            <version>0.2.0-SNAPSHOT</version>
            <type>jar</type>
        </dependency>
    </dependencies>
    <repositories>
        <repository>
            <id>repo-snapshot</id>
            <name>Snapshots bundles</name>
            <url>http://tadmin:tadmin@localhost:8082/archiva/repository/repo-snapshot/</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </repository>
    </repositories>
</project>

package org.talend.test;

import java.util.Map;

import org.apache.camel.CamelContext;
import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;

import esbdemos.simpleroute_0_1.SimpleRoute;

public class RouteTestSample extends CamelTestSupport {
	@EndpointInject(uri = "mock:result")
	protected MockEndpoint resultEndpoint;
	@Produce(uri = "direct:start")
	protected ProducerTemplate template;
	private RouteBuilder builder;

	@Test
	public void testSendMatchingMessage() throws Exception {
		String expectedBody = "bar";
		resultEndpoint.expectedBodiesReceived(expectedBody);
		template.sendBody(expectedBody);
		resultEndpoint.assertIsSatisfied();
	}

	@Test
	public void testSendNotMatchingMessage() throws Exception {
		resultEndpoint.expectedMessageCount(0);
		template.sendBody("foo");
		resultEndpoint.assertIsSatisfied();
	}

	@Override
	protected CamelContext createCamelContext() throws Exception {
		SimpleRoute route = new SimpleRoute();
		// Setup the test aliases
		Map<String, String> uriProperties = route.getUriMap();
		uriProperties.put("start", "direct:start");
		uriProperties.put("end", "mock:result");
		route.loadCustomUriMap(uriProperties);
		// Build the route
		builder = route.Route(false);
		return builder.getContext();
	}

	@Override
	protected RouteBuilder createRouteBuilder() {
		return builder;
	}
}