Guest User

Untitled

a guest
Oct 23rd, 2017
112
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.63 KB | None | 0 0
  1. <!-- ActiveMQ Broker -->
  2. <broker:broker useJmx="false" persistent="false" brokerName="localhost">
  3. <broker:transportConnectors>
  4. <broker:transportConnector name="tcp" uri="tcp://localhost:61616"/>
  5. </broker:transportConnectors>
  6. </broker:broker>
  7.  
  8. <!-- JMS que -->
  9. <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
  10. <property name="connectionFactory">
  11. <bean class="org.apache.activemq.ActiveMQConnectionFactory">
  12. <property name="brokerURL" value="tcp://localhost:61616"/>
  13. </bean>
  14. </property>
  15. </bean>
  16.  
  17. <?xml version="1.0" encoding="UTF-8"?>
  18. <project xmlns="http://maven.apache.org/POM/4.0.0"
  19. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  20. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  21. <modelVersion>4.0.0</modelVersion>
  22.  
  23. <groupId>com.domain.subdomain</groupId>
  24. <artifactId>08-xml-to-jms</artifactId>
  25. <version>1.0-SNAPSHOT</version>
  26.  
  27.  
  28.  
  29. <dependencies>
  30. <!-- https://mvnrepository.com/artifact/org.apache.camel/camel-core -->
  31. <dependency>
  32. <groupId>org.apache.camel</groupId>
  33. <artifactId>camel-core</artifactId>
  34. <version>2.20.0</version>
  35. </dependency>
  36.  
  37. <!-- https://mvnrepository.com/artifact/org.apache.camel/camel-spring -->
  38. <dependency>
  39. <groupId>org.apache.camel</groupId>
  40. <artifactId>camel-spring</artifactId>
  41. <version>2.20.0</version>
  42. </dependency>
  43.  
  44. <dependency>
  45. <groupId>org.apache.camel</groupId>
  46. <artifactId>spi-annotations</artifactId>
  47. <version>2.20.0</version>
  48. </dependency>
  49.  
  50. <!-- https://mvnrepository.com/artifact/org.apache.camel/camel-jms -->
  51. <dependency>
  52. <groupId>org.apache.camel</groupId>
  53. <artifactId>camel-jms</artifactId>
  54. <version>2.20.0</version>
  55. </dependency>
  56.  
  57. <dependency>
  58. <groupId>org.apache.camel</groupId>
  59. <artifactId>camel-http4</artifactId>
  60. <version>2.20.0</version>
  61. </dependency>
  62.  
  63. <dependency>
  64. <groupId>org.apache.camel</groupId>
  65. <artifactId>camel-quartz</artifactId>
  66. <version>2.20.0</version>
  67. </dependency>
  68.  
  69.  
  70. <!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-all -->
  71. <dependency>
  72. <groupId>org.apache.activemq</groupId>
  73. <artifactId>activemq-all</artifactId>
  74. <version>5.15.1</version>
  75. </dependency>
  76.  
  77. <!-- https://mvnrepository.com/artifact/org.apache.xbean/xbean-spring -->
  78. <dependency>
  79. <groupId>org.apache.xbean</groupId>
  80. <artifactId>xbean-spring</artifactId>
  81. <version>4.5</version>
  82. </dependency>
  83.  
  84.  
  85. <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-log4j12 -->
  86. <dependency>
  87. <groupId>org.slf4j</groupId>
  88. <artifactId>slf4j-log4j12</artifactId>
  89. <version>1.7.25</version>
  90. <scope>test</scope>
  91. </dependency>
  92.  
  93.  
  94. </dependencies>
  95.  
  96.  
  97. <build>
  98. <plugins>
  99. <!-- Allows the routes to be run via 'mvn camel:run' -->
  100. <plugin>
  101. <groupId>org.apache.camel</groupId>
  102. <artifactId>camel-maven-plugin</artifactId>
  103. <version>2.20.0</version>
  104. </plugin>
  105. </plugins>
  106. </build>
  107.  
  108. </project>
  109.  
  110. <?xml version="1.0" encoding="UTF-8"?>
  111. <beans xmlns="http://www.springframework.org/schema/beans"
  112. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  113. xmlns:broker="http://activemq.apache.org/schema/core"
  114. xsi:schemaLocation="
  115. http://www.springframework.org/schema/beans
  116. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  117. http://camel.apache.org/schema/spring
  118. http://camel.apache.org/schema/spring/camel-spring.xsd">
  119.  
  120. <!-- Currency Route -->
  121. <bean id="CurrencyRoute" class="com.domain.subdomain.route.CurrencyRoute">
  122. <property name="currencyWsURL" value="www.dnb.no/portalfront/datafiles/miscellaneous/csv/kursliste_ws.xml" />
  123. </bean>
  124.  
  125. <camelContext xmlns="http://camel.apache.org/schema/spring">
  126. <routeBuilder ref="CurrencyRoute"/>
  127. </camelContext>
  128.  
  129.  
  130. <!-- ActiveMQ Broker -->
  131. <broker:broker useJmx="false" persistent="false" brokerName="localhost">
  132. <broker:transportConnectors>
  133. <broker:transportConnector name="tcp" uri="tcp://localhost:61616"/>
  134. </broker:transportConnectors>
  135. </broker:broker>
  136.  
  137. <!-- JMS que -->
  138. <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
  139. <property name="connectionFactory">
  140. <bean class="org.apache.activemq.ActiveMQConnectionFactory">
  141. <property name="brokerURL" value="tcp://localhost:61616"/>
  142. </bean>
  143. </property>
  144. </bean>
  145.  
  146. </beans>
  147.  
  148. package com.domain.subdomain.route;
  149.  
  150. import org.apache.camel.builder.RouteBuilder;
  151.  
  152. public class CurrencyRoute extends RouteBuilder {
  153.  
  154.  
  155. private String currencyWsURL;
  156.  
  157.  
  158.  
  159. @Override
  160. public void configure() {
  161. from("quartz://myTimer?trigger.repeatCount=0")
  162. .log("### Quartz trigger ###")
  163. .to("direct:readFile");
  164.  
  165. from("direct:readFile")
  166. .log("### Read file ###")
  167. .to("https4://" + currencyWsURL)
  168. .to("jms:accounting");
  169. // .to("file:src/main/resources/data/work_in_progress?fileName=kursliste_ws-$simple{date:now:yyyyMMdd}.xml");
  170. }
  171.  
  172. public void setCurrencyWsURL(String currencyWsURL) {
  173. this.currencyWsURL = currencyWsURL;
  174. }
  175. }
Add Comment
Please, Sign In to add comment