Examples of org.apache.camel.CamelContext.addRoutes()

org.apache.camel.CamelContext.addRoutes()
Adds a collection of routes to this context using the given builder to build them.
Important: The added routes will only be started, if {@link CamelContext}is already started. You may want to check the state of {@link CamelContext} beforeadding the routes, using the {@link org.apache.camel.CamelContext#getStatus()} method.
Important: Each route in the same {@link org.apache.camel.CamelContext} must have an unique route id.If you use the API from {@link org.apache.camel.CamelContext} or {@link org.apache.camel.model.ModelCamelContext} to add routes, then anynew routes which has a route id that matches an old route, then the old route is replaced by the new route. @param builder the builder which will create the routes and add them to this context @throws Exception if the routes could not be created for whatever reason

    /**
     * A helper method to create a list of Route objects for a given route builder
     */
    public static List<Route> getRouteList(RouteBuilder builder) throws Exception {
        CamelContext context = new DefaultCamelContext();
        context.addRoutes(builder);
        context.start();
        List<Route> answer = context.getRoutes();
        context.stop();
        return answer;
    }

View Full Code Here

    /**
     * A helper method to create a list of Route objects for a given route builder
     */
    public static List<Route> getRouteList(RouteBuilder builder) throws Exception {
        CamelContext context = new DefaultCamelContext();
        context.addRoutes(builder);
        context.start();
        List<Route> answer = context.getRoutes();
        context.stop();
        return answer;
    }

View Full Code Here

    
    public static void main(String args[]) throws Exception {
        CamelContext camel = new DefaultCamelContext();
        ReportIncidentRoutes routes = new ReportIncidentRoutes();
        routes.setUsingServletTransport(false);
        camel.addRoutes(routes);
        camel.start();
    }


}

View Full Code Here

        // Note we can explicity name the component
        context.addComponent("test-jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
        // END SNIPPET: e2
        // Add some configuration by hand ...
        // START SNIPPET: e3
        context.addRoutes(new RouteBuilder() {


            public void configure() {
                from("test-jms:queue:test.queue").to("file://test");
                // set up a listener on the file component
                from("file://test").process(new Processor() {

View Full Code Here

    }


    public Exchange doSignatureRouteTest(RouteBuilder builder, Exchange e, Map<String, Object> headers) throws Exception {
        CamelContext context = new DefaultCamelContext();
        try {
            context.addRoutes(builder);
            context.start();


            MockEndpoint mock = context.getEndpoint("mock:result", MockEndpoint.class);
            mock.setExpectedMessageCount(1);

View Full Code Here

       System.out.println("#######################################################");


      
      ProcessEventListener delegateListener = processDelegateListener(service);
      delegateListener.setDuccEventDispatcher(eventDispatcher);
      camelContext.addRoutes(this.routeBuilderForIncomingRequests(thisNodeIP, delegateListener));
    
      return service;
      
    } catch( Exception e) {
      e.printStackTrace();

View Full Code Here

     * @throws Exception 
     */
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();
        context.start();
        context.addRoutes(new CamelRouterBuilder());
        Thread.sleep(1000);
        // JAXWSClient invocation
        JAXWSClient jaxwsClient = new JAXWSClient();
        BookStore bookStore = jaxwsClient.getBookStore();

View Full Code Here

        runScript(scriptName);
        List<RouteBuilder> list = RubyCamel.getRoutes();


        log.info("Found route builders: " + list);
        for (RouteBuilder routeBuilder : list) {
            answer.addRoutes(routeBuilder);
        }


        return answer;
    }

View Full Code Here


    public void testNoMultipleConsumersTest() throws Exception {
        CamelContext container = new DefaultCamelContext();
        container.disableJMX();


        container.addRoutes(new RouteBuilder() {
            public void configure() throws Exception {
                from("direct:in").to("mock:result");


                from("direct:in").to("mock:result");
            }

View Full Code Here

        CamelContext container = new DefaultCamelContext();


        final AtomicBoolean invoked = new AtomicBoolean();


        // lets add some routes
        container.addRoutes(new RouteBuilder() {
            public void configure() {
                from("direct:test.a").to("direct:test.b");
                from("direct:test.b").process(new Processor() {
                    public void process(Exchange e) {
                        invoked.set(true);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.