CamelTestSupport example

gistfile1.java

public class SwitchyardComponentTest extends CamelTestSupport {
    private String _serviceName = "testServiceName";

    @Before
    public void setup() throws Exception {
        ServiceReferences.clear();
    }
    
    @Test
    public void sendToSwitchyardInOut() throws Exception {
        final String expectedResponse = "replacedContent";
        final String payload = "bajja";
        final InOnlyService inService = new InOnlyService("testServiceName");
        
        final ServiceReference serviceReference = getServiceDomain().registerService(new QName(_serviceName), new ResponseService(expectedResponse), inService);
        ServiceReferences.add(serviceReference.getName(), serviceReference);
        
        final String response = (String) _template.requestBody("direct:input", payload);
        assertThat(response, is(equalTo(expectedResponse)));
    }
    
    @Test
    public void sendToSwitchyardInOnly() throws Exception {
        final String payload = "bajja";
        final MockHandler mockService = new MockHandler();
        final InOnlyService inService = new InOnlyService("testServiceName");
        final ServiceReference serviceReference = getServiceDomain().registerService(new QName(_serviceName), mockService, inService);
        ServiceReferences.add(serviceReference.getName(), serviceReference);
        
        template.sendBody("direct:input", payload);
        
        assertThat(mockService.getMessages().size(), is(1));
        final String actualPayload = mockService.getMessages().iterator().next().getMessage().getContent(String.class);
        assertThat(actualPayload, is(equalTo(payload)));
    }
    
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder()
        {
            public void configure() throws Exception {
                from("direct:input")
                .to("switchyard://" + _serviceName.toString() + "?operationName=" + _serviceName.toString())
                .to("mock:result");
            }
        };
    }

    private static class ResponseService extends BaseHandler {
        private final String _response;
        
        public ResponseService(final String response) {
            this._response = response;
            
        }
        @Override
        public void handleMessage(final Exchange exchange) throws HandlerException {
            final Message responseMessage = exchange.createMessage().setContent(_response);
            exchange.send(responseMessage);
        }
    }

}