List of addRoutes() Examples

Examples of 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
org.apache.camel.impl.DefaultCamelContext.addRoutes()
org.apache.camel.spring.SpringCamelContext.addRoutes()
org.fusesource.ide.camel.model.RouteContainer.addRoutes()
Adds the list of route definitions after loading the routes from a file or runtime
org.zoolu.sip.message.Message.addRoutes()

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

    }


    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

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

    }


    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

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

     */
    @Test
    public void testRestart() throws Exception {
        DefaultCamelContext camel = new DefaultCamelContext();


        camel.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("quartz2://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
            }
        });

View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

    }


    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

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

        Context context = new JndiContext();
        context.bind("testnode", node);
        node.set("ksession", session);


        CamelContext camelContext = new DefaultCamelContext(context);
        camelContext.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {          
                JaxbDataFormat jdf = new JaxbDataFormat();
                jdf.setContextPath("org.drools.camel.testdomain");
                jdf.setPrettyPrint(true);

View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

        Context context = new JndiContext();
        context.bind("testnode", node);
        node.set("ksession", session);
        
        CamelContext camelContext = new DefaultCamelContext(context);
        camelContext.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct:test-session").policy(new DroolsPolicy()).unmarshal("json").to("drools://testnode/ksession").marshal("json");
                from("direct:unmarshall").policy(new DroolsPolicy()).unmarshal("json");
                from("direct:marshall").policy(new DroolsPolicy()).marshal("json");

View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

        CamelContext camelContext = new DefaultCamelContext(context);
        // END SNIPPET: register


        // START SNIPPET: route
        // lets add simple route
        camelContext.addRoutes(new RouteBuilder() {
            public void configure() {
                from("direct:hello").to("pojo:bye");
            }
        });
        // END SNIPPET: route

View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

        final CountDownLatch latch = new CountDownLatch(1);


        CamelContext context = new DefaultCamelContext();


        // lets add some routes
        context.addRoutes(new RouteBuilder() {
            public void configure() {
                from("seda:test.a").to("seda:test.b");
                from("seda:test.b").process(new Processor() {
                    public void process(Exchange e) {
                        log.debug("Received exchange: " + e.getIn());

View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

        final CountDownLatch latch = new CountDownLatch(1);


        CamelContext context = new DefaultCamelContext();


        // lets add some routes
        context.addRoutes(new RouteBuilder() {
            public void configure() {
                from("seda:test.a").to("seda:test.b");
                from("seda:test.b").process(new Processor() {
                    public void process(Exchange e) {
                        log.debug("Received exchange: " + e.getIn());

View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRoutes()

                 * TODO keep old DSL? .intercept() .add(interceptor1)
                 * .add(interceptor2) .target().to("direct:d");
                 */
            }
        };
        container.addRoutes(builder);
        container.start();


        Endpoint<Exchange> endpoint = container.getEndpoint("direct:a");
        Exchange exchange = endpoint.createExchange();
        Producer<Exchange> producer = endpoint.createProducer();

View Full Code Here

0 1 2 3 4 5

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.