|
1
2
3
4
5
6
7
|
import org.apache.camel.builder.RouteBuilder;public class DispatcherRouteBuilder extends RouteBuilder { @Override public void configure() throws Exception { from("activemq:queue:EVENTS").to("log:Events?showAll=true"); }} |
๋Junit test จะทำการ start message broker และจะ start camel แล้วจะทำการส่ง message ไปยัง queue
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
import org.apache.activemq.broker.BrokerService;import org.apache.camel.builder.RouteBuilder;import org.apache.camel.test.junit4.CamelTestSupport;import org.junit.BeforeClass;import org.junit.Test;public class DispatcherRouteBuilderTest extends CamelTestSupport { @Override protected RouteBuilder createRouteBuilder() throws Exception { return new DispatcherRouteBuilder(); } @BeforeClass public static void setUpClass() throws Exception { BrokerService brokerSvc = new BrokerService(); brokerSvc.setBrokerName("TestBroker"); brokerSvc.start(); } @Test public void testConfigure() throws Exception { template.sendBody("activemq:queue:EVENTS", "HelloWorld!"); Thread.sleep(3000); }} |
dependencies ที่ใช้ใน Maven:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
<dependencies> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-core</artifactId> <version>2.4.0-fuse-00-00</version> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-test</artifactId> <version>2.4.0-fuse-00-00</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-jms</artifactId> <version>2.4.0-fuse-00-00</version> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-camel</artifactId> <version>5.4.0-fuse-00-00</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.4.0-fuse-00-00</version> <scope>test</scope> </dependency></dependencies> |
