Package org.apache.camel.builder

Examples of org.apache.camel.builder.RouteBuilder

70
71
72
73
74
75
76
77
78
79
80
        assertListSize("Number of exceptions", resultEndpoint.getFailures(), 1);
    }

    @Override
    protected RouteBuilder createRouteBuilder() {
        return new RouteBuilder() {
            @Override
            public void configure() {
                from("direct:start").to("beanstalk:" + tubeName + "?command=bury").to("mock:result");
            }
        };
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    @Mock
    T mockObject;
   
    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
           
            @Override
            public void configure() throws Exception {
                from("direct:in").to("docker://" + getOperation().toString());
               
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        verify(client, atLeast(1)).delete(jobId);
    }

    @Override
    protected RouteBuilder createRouteBuilder() {
        return new RouteBuilder() {
            @Override
            public void configure() {
                from("beanstalk:tube?consumer.awaitJob=false").process(processor).to("mock:result");
            }
        };
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
    @Mock
    private RemoveImageCmd mockObject;
   
    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
           
            @Override
            public void configure() throws Exception {
                from("direct:in").to("docker://" + getOperation().toString() + "?imageId=" + imageId + "&noPrune=" + noPrune + "&force=" + force);
               
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
        assertListSize("Number of exceptions", resultEndpoint.getFailures(), 1);
    }

    @Override
    protected RouteBuilder createRouteBuilder() {
        return new RouteBuilder() {
            @Override
            public void configure() {
                from("direct:start").to("beanstalk:" + tubeName + "?command=delete").to("mock:result");
            }
        };
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
        assertMockEndpointsSatisfied();
    }

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("netty4-http:http://0.0.0.0:{{port}}/foo?matchOnUriPrefix=true"
                        + "&securityConfiguration.realm=karaf&securityConfiguration.securityConstraint=#myConstraint")
                    .to("mock:input")
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
        return camelContext;
    }

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                // enable async in only mode on the consumer
                from("sjms:queue:start?synchronous=false")
                        .choice()
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
     * @return
     * @throws Exception
     */
    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            public void configure() {
                from("direct:start")
                    .to("sjms:topic:" + TEST_DESTINATION_NAME);
               
                from("direct:finish")
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
            return;
        }

        getMockEndpoint("mock:input").expectedBodiesReceived("Hello World");

        context.addRoutes(new RouteBuilder() {
            public void configure() {
                from("netty4-http:https://localhost:{{port}}?ssl=true&passphrase=changeit&keyStoreResource=jsse/localhost.ks&trustStoreResource=jsse/localhost.ks")
                        .to("mock:input")
                        .process(new Processor() {
                            public void process(Exchange exchange) throws Exception {
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
       
    }

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("netty4-http:http://0.0.0.0:9001/foo?compression=true")
                    .transform().constant("Bye World").setHeader("content-type").constant("text/plain; charset=\"UTF-8\"");
            }
View Full Code Here
TOP

Related Classes of org.apache.camel.builder.RouteBuilder

  • org.apache.activemq.camel.component.ComplexRequestReplyTest
  • org.apache.camel.CamelContext
  • org.apache.camel.component.avro.AvroSettingsTest
  • org.apache.camel.component.aws.sqs.SqsFilterMessagesWithNoDeleteTest
  • org.apache.camel.component.bean.BeanOverloadedCovariantMethodTest
  • org.apache.camel.component.bean.BeanOverloadedMethodFQNTest
  • org.apache.camel.component.bean.BeanWithInputStreamBodyTest
  • org.apache.camel.component.bean.BeanWithMethodHeaderTest
  • org.apache.camel.component.directvm.DirectVmConsumerExpressionTest
  • org.apache.camel.component.disruptor.DisruptorBufferingTest
    • Copyright © 2018 www.massapicom. 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.