Examples of addRoutes()

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

26
27
28
29
30
31
32
33
34
35
36
public class Starter {

    public void run() throws Exception {
        CamelContext context = new DefaultCamelContext();
        context.addComponent("properties", new PropertiesComponent("sampleconfig.properties"));
        context.addRoutes(new OrderRouteBuilder());
        context.start();
        System.in.read();
        context.stop();
    }
   
View Full Code Here

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

30
31
32
33
34
35
36
37
38
39
40
   
    public void run() throws Exception {
        CamelContext context = new DefaultCamelContext();
        addJmsComponent(context);
        context.setTracing(true);
        context.addRoutes(new Jpa2JmsRoute());
        context.start();
        System.in.read();
        context.stop();
    }
View Full Code Here

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

31
32
33
34
35
36
37
38
39
40
41
    public void run() throws Exception {
        CamelContext context = new DefaultCamelContext();
        JmsConfiguration jmsConfig = new JmsConfiguration(new ActiveMQConnectionFactory("tcp://localhost:61616"));
        context.addComponent("jms", new JmsComponent(jmsConfig ));
        context.setTracing(true);
        context.addRoutes(new Jms2RestRoute());
        context.start();
        System.in.read();
        context.stop();
    }
   
View Full Code Here

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

32
33
34
35
36
37
38
39
40
41
42
        twitterComponent.setConsumerKey("");
        twitterComponent.setConsumerSecret("");
        twitterComponent.setAccessToken("");
        twitterComponent.setAccessTokenSecret("");
        context.setTracing(true);
        context.addRoutes(new VotingRoutes());
        context.start();
        System.in.read();
        context.stop();
    }
   
View Full Code Here

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

430
431
432
433
434
435
436
437
438
439
440
    }

    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.CamelContext.addRoutes()

46
47
48
49
50
51
52
53
54
55
56
            CamelContext camelContext = (CamelContext) bean;
            LOG.debug("Post-processing CamelContext bean: {}", camelContext.getName());
            for (RoutesBuilder routesBuilder : applicationContext.getBeansOfType(RoutesBuilder.class).values()) {
                try {
                    LOG.debug("Injecting following route into the CamelContext: {}", routesBuilder);
                    camelContext.addRoutes(routesBuilder);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
            if (camelContextConfiguration != null) {
View Full Code Here

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

1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
    }

    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.CamelContext.addRoutes()

321
322
323
324
325
326
327
328
329
330
331
    }

    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.CamelContext.addRoutes()

83
84
85
86
87
88
89
90
91
92
93
        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.CamelContext.addRoutes()

62
63
64
65
66
67
68
69
70
71
72
        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
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.