Package org.apache.camel.component.mock

Examples of org.apache.camel.component.mock.MockEndpoint.expectedFileExists()

92
93
94
95
96
97
98
99
100
101
102
        });
        context.start();

        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedMessageCount(1);
        mock.expectedFileExists("./target/keep/out/hello.txt");
        mock.message(0).header(Exchange.FILE_LAST_MODIFIED).isNotNull();

        assertMockEndpointsSatisfied();

        long t1 = mock.getReceivedExchanges().get(0).getIn().getHeader(Exchange.FILE_LAST_MODIFIED, Date.class).getTime();
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
    public void testSplitPropertiesFileAndRoute() throws Exception {
        MockEndpoint foo = getMockEndpoint("mock:foo");
        foo.expectedBodiesReceived("[foo=1, foo=4]");

        // after the file is routed it should be moved to done
        foo.expectedFileExists("target/file/splitprop/done/myprop.txt", body);

        MockEndpoint bar = getMockEndpoint("mock:bar");
        bar.expectedBodiesReceived("[bar=2, bar=3]");

        template.sendBodyAndHeader("file://target/file/splitprop", body, Exchange.FILE_NAME, "myprop.txt");
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    public void testToAsyncHandoverCompletion() throws Exception {
        deleteDirectory("target/toasync");

        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Bye World");
        mock.expectedFileExists("target/toasync/done/hello.txt");

        template.sendBodyAndHeader("file://target/toasync", "World", Exchange.FILE_NAME, "hello.txt");

        Thread.sleep(1000);
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        });
        context.start();

        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Bye Big World");
        mock.expectedFileExists("target/filelanguage/backup/123.txt", "Bye Big World");

        template.sendBodyAndHeader("file://target/filelanguage/", "Bye Big World", Exchange.FILE_NAME, "report3.txt");
        assertMockEndpointsSatisfied();
    }
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        });
        context.start();

        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Hello Big World");
        mock.expectedFileExists("target/backup/report4.txt.bak");

        template.sendBodyAndHeader("file://target/filelanguage/", "Hello Big World", Exchange.FILE_NAME, "report4.txt");
        assertMockEndpointsSatisfied();
    }
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
        });
        context.start();

        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Bean Language Rules The World");
        mock.expectedFileExists("target/filelanguage/123");

        template.sendBodyAndHeader("file://target/filelanguage/", "Bean Language Rules The World",
                Exchange.FILE_NAME, "report5.txt");
        assertMockEndpointsSatisfied();
    }
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
    }

    public void testAppend() throws Exception {
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Bye World");
        mock.expectedFileExists("target/file/hello.txt", "Bye World");

        template.sendBodyAndHeader("file://target/file?fileExist=Append", "Bye World", Exchange.FILE_NAME, "hello.txt");

        assertMockEndpointsSatisfied();
    }
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
    }

    public void testFilePollEnrich() throws Exception {
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Hello World");
        mock.expectedFileExists("target/pollenrich/done/hello.txt");

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

        assertMockEndpointsSatisfied();
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
    }

    public void xxxtestAbsolute() throws Exception {
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Hello World");
        mock.expectedFileExists("/opt/feeds/ebook/in/.camel/hello.txt");

        template.sendBodyAndHeader("file:/opt/feeds/ebook/in", "Hello World", Exchange.FILE_NAME, "hello.txt");

        assertMockEndpointsSatisfied();
    }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
    public void testMoveAndMoveFailed() throws Exception {
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("Hello World");

        mock.expectedFileExists("target/failed/moved/hello.txt", "Hello World");
        mock.expectedFileExists("target/failed/error/bye-error.txt", "Kabom");

        template.sendBodyAndHeader("file://target/failed", "Hello World", Exchange.FILE_NAME, "hello.txt");
        template.sendBodyAndHeader("file://target/failed", "Kabom", Exchange.FILE_NAME, "bye.txt");
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.