Examples of sendBodyAndHeader()

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

59
60
61
62
63
64
65
66
67
68
69
        // do our testing
        MockEndpoint mock = ctx.getEndpoint("mock:result", MockEndpoint.class);
        mock.expectedMessageCount(1);

        myTemplate.sendBodyAndHeader("file:target/foo", "Hello World", Exchange.FILE_NAME, "hello.txt");

        mock.assertIsSatisfied();

        myTemplate.stop();
    }
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

57
58
59
60
61
62
63
64
65
66
67
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedMessageCount(NUMBER_OF_MESSAGES);

        ProducerTemplate template = context.createProducerTemplate();
        for (int i = 0; i < NUMBER_OF_MESSAGES; i++) {
            template.sendBodyAndHeader("seda:fork", "Test Message: " + i,
                    "seqnum", new Long(i));
        }

        long expectedTime = NUMBER_OF_MESSAGES
                * (RandomSleepProcessor.MAX_PROCESS_TIME + RandomSleepProcessor.MIN_PROCESS_TIME)
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

66
67
68
69
70
71
72
73
74
75
76
        MockEndpoint mock = ctx.getEndpoint("mock:results", MockEndpoint.class);
        ProducerTemplate template = ctx.createProducerTemplate();
        mock.expectedMessageCount(2);
        template.sendBodyAndHeader("direct:start", "Test 1", JcloudsConstants.BLOB_NAME, "blob1");
        template.sendBodyAndHeader("direct:start", "Test 2", JcloudsConstants.BLOB_NAME, "blob2");
        assertMockEndpointsSatisfied();
    }

    @Configuration
    public static Option[] configure() throws Exception {
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

65
66
67
68
69
70
71
72
73
74
75
        CamelContext ctx = getOsgiService(CamelContext.class, "(camel.context.symbolicname=CamelBlueprintJcloudsTestBundle)", 20000);

        MockEndpoint mock = ctx.getEndpoint("mock:results", MockEndpoint.class);
        ProducerTemplate template = ctx.createProducerTemplate();
        mock.expectedMessageCount(2);
        template.sendBodyAndHeader("direct:start", "Test 1", JcloudsConstants.BLOB_NAME, "blob1");
        template.sendBodyAndHeader("direct:start", "Test 2", JcloudsConstants.BLOB_NAME, "blob2");
        assertMockEndpointsSatisfied();
    }

    @Configuration
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

48
49
50
51
52
53
54
55
56
57
58
        //getInstalledBundle("CamelBlueprintKratiTestBundle").start();
        CamelContext ctx = getOsgiService(CamelContext.class, "(camel.context.symbolicname=CamelBlueprintKratiTestBundle)", 20000);
        MockEndpoint mock = ctx.getEndpoint("mock:results", MockEndpoint.class);
        ProducerTemplate template = ctx.createProducerTemplate();
        mock.expectedMessageCount(2);
        template.sendBodyAndHeader("direct:put", new SomeObject("1", "Test 1"), KratiConstants.KEY, "1");
        template.sendBodyAndHeader("direct:put", new SomeObject("2", "Test 2"), KratiConstants.KEY, "2");
        template.sendBodyAndHeader("direct:put", new SomeObject("3", "Test 3"), KratiConstants.KEY, "1");
        assertMockEndpointsSatisfied();
    }
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

49
50
51
52
53
54
55
56
57
58
59
        CamelContext ctx = getOsgiService(CamelContext.class, "(camel.context.symbolicname=CamelBlueprintKratiTestBundle)", 20000);
        MockEndpoint mock = ctx.getEndpoint("mock:results", MockEndpoint.class);
        ProducerTemplate template = ctx.createProducerTemplate();
        mock.expectedMessageCount(2);
        template.sendBodyAndHeader("direct:put", new SomeObject("1", "Test 1"), KratiConstants.KEY, "1");
        template.sendBodyAndHeader("direct:put", new SomeObject("2", "Test 2"), KratiConstants.KEY, "2");
        template.sendBodyAndHeader("direct:put", new SomeObject("3", "Test 3"), KratiConstants.KEY, "1");
        assertMockEndpointsSatisfied();
    }

    @Configuration
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

50
51
52
53
54
55
56
57
58
59
60
        MockEndpoint mock = ctx.getEndpoint("mock:results", MockEndpoint.class);
        ProducerTemplate template = ctx.createProducerTemplate();
        mock.expectedMessageCount(2);
        template.sendBodyAndHeader("direct:put", new SomeObject("1", "Test 1"), KratiConstants.KEY, "1");
        template.sendBodyAndHeader("direct:put", new SomeObject("2", "Test 2"), KratiConstants.KEY, "2");
        template.sendBodyAndHeader("direct:put", new SomeObject("3", "Test 3"), KratiConstants.KEY, "1");
        assertMockEndpointsSatisfied();
    }

    @Configuration
    public static Option[] configure() throws Exception {
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

45
46
47
48
49
50
51
52
53
54
55
        MockEndpoint mock = ctx.getEndpoint("mock:result", MockEndpoint.class);
        mock.expectedMessageCount(1);

        ProducerTemplate template = ctx.createProducerTemplate();
        template.sendBodyAndHeader("direct:start", "someone@somewhere.org", "index", 1);
        template.sendBodyAndHeader("direct:start", "someoneelse@somewhere.org", "index", 2);

        assertMockEndpointsSatisfied();
    }
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

46
47
48
49
50
51
52
53
54
55
56
        MockEndpoint mock = ctx.getEndpoint("mock:result", MockEndpoint.class);
        mock.expectedMessageCount(1);

        ProducerTemplate template = ctx.createProducerTemplate();
        template.sendBodyAndHeader("direct:start", "someone@somewhere.org", "index", 1);
        template.sendBodyAndHeader("direct:start", "someoneelse@somewhere.org", "index", 2);

        assertMockEndpointsSatisfied();
    }

    @Configuration
View Full Code Here

Examples of org.apache.camel.ProducerTemplate.sendBodyAndHeader()

53
54
55
56
57
58
59
60
61
62
63
        ProducerTemplate producerTemplate = camelContext.createProducerTemplate();

        producerTemplate.start();

        producerTemplate.sendBodyAndHeader("file:target/data", "Hello World", Exchange.FILE_NAME, "hello.txt");

        producerTemplate.stop();

        mock.assertIsSatisfied();
    }
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.