Examples of addRoutes()

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

37
38
39
40
41
42
43
44
45
46
47
        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

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

45
46
47
48
49
50
51
52
53
54
55
        });

        CamelContext camelContext = new DefaultCamelContext(context);

        // lets add some routes
        camelContext.addRoutes(new RouteBuilder() {
            public void configure() {
                from("timer://foo?fixedRate=true&delay=0&period=500").to("pojo:bar");
            }
        });
View Full Code Here

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

49
50
51
52
53
54
55
56
57
58
59
        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("rmi://localhost:1099/bye");

                // When exposing an RMI endpoint, the interfaces it exposes must
                // be configured.
View Full Code Here

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

858
859
860
861
862
863
864
865
866
867
868
    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()

51
52
53
54
55
56
57
58
59
60
61
        try {
            CamelContext context = new DefaultCamelContext();

            final CountDownLatch latch = new CountDownLatch(ITERS);

            context.addRoutes(new RouteBuilder() {

                @Override
                public void configure() throws Exception {
                    from("direct:a").thread(4).process(new Processor() {
View Full Code Here

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

90
91
92
93
94
95
96
97
98
99
100
    protected void runTest(RouteBuilder builder, ArrayList<String> expected, String header) throws Exception {

        order.clear();
        CamelContext container = new DefaultCamelContext();

        container.addRoutes(builder);
        container.start();

        Endpoint endpoint = container.getEndpoint("direct:a");
        Exchange exchange = endpoint.createExchange();
        if (header != null) {
View Full Code Here

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

49
50
51
52
53
54
55
56
57
58
59
        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("rmi://localhost:9876/bye");

                // When exposing an RMI endpoint, the interfaces it exposes must
                // be configured.
View Full Code Here

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

64
65
66
67
68
69
70
71
72
73
74
        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()

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

61
62
63
64
65
66
67
68
69
70
71
        // Start the bank server
        BankServer bankServer = new BankServer();
        bankServer.start();

        // Start the camel context
        context.addRoutes(new LoanBroker());
        context.start();

        // Start the loan broker
        Thread.sleep(5 * 60 * 1000);
        context.stop();
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.