I understand your point but I think that having to start switchyard runtime in order to be able to test a Camel Route Builder can become an overkill. The reason why I say this is because SwitchYardRunner (as well as the rest of the Arquillian based testing) is a framework for Integration Testing which imposes replicating as much as possible the container and the resources in it (in my case I have to set up resources related to transactions). From my point of view, it would be easier to be able to use the CamelTestSupport and have the switchyard endpoint mocked so that I can verify that tests flow according to the routing.

At the moment when I try to mock the switchyard components by using CamelTestSupport together with the @Produce and @EndpointInject annotations, I get the following error:

java.lang.IllegalArgumentException: Invalid type: org.apache.camel.component.mock.MockEndpoint which cannot be injected via @EndpointInject/@Produce for: Endpoint[switchyard://MyService

I am afraid it hasnt worked as I get the same error.

Nevertheless I do the this new line in the logging:

17:41:26,968 INFO  [org.apache.camel.impl.InterceptSendToMockEndpointStrategy] Adviced endpoint [switchyard://myService] with mock endpoint [mock:switchyard:myService]

But at the end the error message is the same:

java.lang.IllegalArgumentException: Invalid type: org.apache.camel.component.mock.MockEndpoint which cannot be injected via @EndpointInject/@Produce for: Endpoint[switchyard://myService]
          at org.apache.camel.impl.CamelPostProcessorHelper.getInjectionValue(CamelPostProcessorHelper.java:164)
          at org.apache.camel.spring.CamelBeanPostProcessor.injectField(CamelBeanPostProcessor.java:208)
          at org.apache.camel.spring.CamelBeanPostProcessor$1.doWith(CamelBeanPostProcessor.java:196)
          at org.springframework.util.ReflectionUtils.doWithFields(ReflectionUtils.java:513)
          at org.springframework.util.ReflectionUtils.doWithFields(ReflectionUtils.java:490)
          at org.apache.camel.spring.CamelBeanPostProcessor.injectFields(CamelBeanPostProcessor.java:192)
          at org.apache.camel.spring.CamelBeanPostProcessor.postProcessBeforeInitialization(CamelBeanPostProcessor.java:94)
          at org.apache.camel.test.junit4.CamelTestSupport.postProcessTest(CamelTestSupport.java:307)
          at org.apache.camel.test.junit4.CamelTestSupport.doSetUp(CamelTestSupport.java:219)
          at org.apache.camel.test.junit4.CamelTestSupport.setUp(CamelTestSupport.java:167)
          at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
          at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
          at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
          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.junit.runners.Suite.runChild(Suite.java:128)
          at org.junit.runners.Suite.runChild(Suite.java:24)
          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.runners.ParentRunner.run(ParentRunner.java:300)
          at org.junit.runner.JUnitCore.run(JUnitCore.java:157)
          at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:63)

Any ideas why this might be happening would be much appreciated! Thanks.

I have tried what you have suggested but I continue to run into a NullPointerException when SwitchyardProducer tries to lookupServiceReference.

My route builder looks like this:

@Route(SwitchyardCamelService.class)
public class SwitchyardRouteBuilder extends RouteBuilder {


    protected static final String ENDPOINT_SERVICE_CAMEL = "{{SwitchyardCamelService}}";
    protected static final String ENDPOINT_SERVICE_A = "{{SwitchyardServiceA}}";
    protected static final String ENDPOINT_SERVICE_B = "{{SwitchyardServiceB}}";
    protected static final String ENDPOINT_SERVICE_C = "{{SwitchyardServiceC}}";


    @Override
    public void configure() throws Exception {


        final ModelCamelContext context = getContext();
        PropertiesComponent propertiesComponent = context.getComponent("properties", PropertiesComponent.class);
        propertiesComponent.setLocation("classpath:router.properties");


        String camelService = context.resolvePropertyPlaceholders(ENDPOINT_SERVICE_CAMEL);
        String serviceA= context.resolvePropertyPlaceholders(ENDPOINT_SERVICE_A);
        String serviceB = context.resolvePropertyPlaceholders(ENDPOINT_SERVICE_B);
        String serviceC = context.resolvePropertyPlaceholders(ENDPOINT_SERVICE_C);


        from(centralToCMDBServiceEndpoint)
                .choice()
                    .when(and(body().isInstanceOf(EntityA.class), header("operation").isEqualTo("save")))
                        .log("EntityA operation")
                        .to(serviceA + "?operationName=save")
                        .to(serviceC)
                    .when(and(body().isInstanceOf(EntityA.class), header("operation").isEqualTo("update")))
                        .log("EntityA update operation")
                        .to(serviceA + "?operationName=update")
                        .to(serviceC)
                    .when(and(body().isInstanceOf(EntityB.class), header("operation").isEqualTo("save")))
                        .log("EntityB save operation")
                        .to(serviceB + "?operationName=save")
                        .to(serviceC)
                    .when(and(body().isInstanceOf(EntityB.class), header("operation").isEqualTo("update")))
                        .log("EntityB update operation")
                        .to(serviceB + "?operationName=update")
                        .to(serviceC)
                    .otherwise()
                        .choice()
                            .when(or(header("operation").isNotEqualTo("save"), header("operation").isNotEqualTo("update")))
                                .log("Unsupported operation")
                                .throwException(new OperationNotSupportedException())
                            .when(or(not(body().isInstanceOf(EntityA.class)), not(body().isInstanceOf(EntityB.class))))
                                .log("Unsupported entity")
                                .throwException(new EntityNotSupportedException())
                            .otherwise()
                                .log("Unexpected condition met")
                        .end()
                .end();
    }
}

And my CamelTest like this:

/**
 * @author: Eduardo de Vera
 * Date: 6/29/12
 * Time: 12:41 AM
 */
public class SwitchyardRouterBuilderTest extends CamelTestSupport {

    protected static final String MOCK_ENDPOINT_SERVICE_A = "mock:switchyard:serviceA";
    protected static final String MOCK_ENDPOINT_SERVICE_B = "mock:switchyard:serviceB";
    protected static final String MOCK_ENDPOINT_SERVICE_C = "mock:switchyard:serviceC";

    @Produce(uri = CentralToCMDBRouteBuilder. ENDPOINT_SERVICE_CAMEL)
    private ProducerTemplate producerTemplate;

    @EndpointInject(uri = MOCK_ENDPOINT_SERVICE_B)
    private MockEndpoint mockServiceB;

    @EndpointInject(uri = MOCK_ENDPOINT_SERVICE_A)
    private MockEndpoint mockServiceA;
    @EndpointInject(uri = MOCK_ENDPOINT_SERVICE_C)
    private MockEndpoint mockServiceC;

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new CentralToCMDBRouteBuilder() {
            @Override
            public void configure() throws Exception {
                interceptSendToEndpoint(CentralToCMDBRouteBuilder.ENDPOINT_SERVICE_A)
                        .skipSendToOriginalEndpoint()
                        .to(MOCK_ENDPOINT_SERVICE_A);
                interceptSendToEndpoint(CentralToCMDBRouteBuilder.ENDPOINT_SERVICE_B)
                        .skipSendToOriginalEndpoint()
                        .to(MOCK_ENDPOINT_SERVICE_B);
                interceptSendToEndpoint(CentralToCMDBRouteBuilder.ENDPOINT_SERVICE_C)
                        .skipSendToOriginalEndpoint()
                        .to(MOCK_ENDPOINT_SERVICE_C);
                super.configure();
            }
        };
    }

    @Test
    public void testSendHostAndSave() throws Exception {
        mockServiceA.expectedMessageCount(1);
        mockServiceC.expectedMessageCount(1);

        EnityA body = new EntityA();
        producerTemplate.sendBodyAndHeader(body, "operation", "save");

        mockServiceA.assertIsSatisfied();
        mockServiceC.assertIsSatisfied();
    }

    protected CamelContext createCamelContext() throws Exception {
        CamelContext context = super.createCamelContext();
        //Preparing properties
        PropertiesComponent prop = context.getComponent("properties", PropertiesComponent.class);
        prop.setLocation("classpath:router.properties");

        return context;
    }

    @Override
    public String isMockEndpoints() {
        return "switchyard*";
    }

    @Override
    public boolean isUseDebugger() {
        return true;
    }

    @Override
    protected void debugBefore(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String label) {
        System.out.println("Id:" + id + ", Label:" + label);
    }

}

Worked like a charm! Thanks a lot for your help. I think it is a must to be able to test RouteBuilder independently from SwitchYard in order to have more fine grained control over the tests.