gistfile1.java

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.apache.http.client.HttpClient;
import org.apache.http.impl.client.DefaultHttpClient;
import org.junit.Test;

import java.io.IOException;

public class JaxrsTesting extends CamelTestSupport {

    private static final String PORT_PATH = AvailablePortFinder.getNextAvailable() + "/CxfRsTesting";
    private static final String CXF_RS_ENDPOINT_URI = "cxfrs:http://localhost:" + PORT_PATH +
            "/rest?resourceClasses=com.my.project.JaxrsTestingServiceResource" +
            "&bindingStyle=SimpleConsumer";

    private HttpClient httpClient;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        httpClient = new DefaultHttpClient();
    }

    @Override
    public void tearDown() throws Exception {
        super.tearDown();
        httpClient.getConnectionManager().shutdown();
    }

    @Override
    protected RouteBuilder createRouteBuilder() {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from(CXF_RS_ENDPOINT_URI)
                    .recipientList(simple("direct:${header.operationName}"));

                from("direct:getFoo").process(new Processor() {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        exchange.getOut().setBody("Hello there!");
                    }
                });
            }
        };
    }
}