1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.openehealth.ipf.platform.camel.core;
17
18 import org.apache.camel.EndpointInject;
19 import org.apache.camel.ExchangePattern;
20 import org.apache.camel.ProducerTemplate;
21 import org.apache.camel.component.mock.MockEndpoint;
22 import org.junit.After;
23 import org.junit.runner.RunWith;
24 import org.springframework.beans.factory.annotation.Autowired;
25 import org.springframework.test.context.ContextConfiguration;
26 import org.springframework.test.context.TestExecutionListeners;
27 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
28 import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;
29
30 import java.util.ArrayList;
31 import java.util.List;
32
33
34
35
36 @RunWith(SpringJUnit4ClassRunner.class)
37 @ContextConfiguration(locations = { "/context-core.xml" })
38 @TestExecutionListeners({DependencyInjectionTestExecutionListener.class})
39 public abstract class AbstractRouteTest {
40
41 @Autowired
42 protected ProducerTemplate producerTemplate;
43
44 @EndpointInject(uri="mock:mock")
45 protected MockEndpoint mock;
46
47 @After
48 public void tearDown() throws Exception {
49 mock.reset();
50 }
51
52 protected List<String> sendBodies(String endpointUri, ExchangePattern pattern, String body, int repeats) {
53 ArrayList<String> result = new ArrayList<>(repeats);
54 for (int i = 0; i < repeats; i++) {
55 result.add((String)producerTemplate.sendBody(endpointUri, pattern, body));
56 }
57 return result;
58 }
59
60 }