Author: hadrian
Date: Tue Jan 10 01:29:53 2012
New Revision: 1229439
URL: http://svn.apache.org/viewvc?rev=1229439&view=rev
Log:
Add support for scheduled routes via camel-quartz
Modified:
labs/magnet/core/pom.xml
labs/magnet/core/src/main/java/org/apache/labs/magnet/core/CoreRouteBuilder.java
labs/magnet/core/src/test/java/org/apache/labs/magnet/core/RestServiceTest.java
labs/magnet/magnet/pom.xml
Modified: labs/magnet/core/pom.xml
URL:
http://svn.apache.org/viewvc/labs/magnet/core/pom.xml?rev=1229439&r1=1229438&r2=1229439&view=diff
==============================================================================
--- labs/magnet/core/pom.xml (original)
+++ labs/magnet/core/pom.xml Tue Jan 10 01:29:53 2012
@@ -90,6 +90,10 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-velocity</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-quartz</artifactId>
+ </dependency>
<dependency>
<groupId>org.springframework</groupId>
Modified:
labs/magnet/core/src/main/java/org/apache/labs/magnet/core/CoreRouteBuilder.java
URL:
http://svn.apache.org/viewvc/labs/magnet/core/src/main/java/org/apache/labs/magnet/core/CoreRouteBuilder.java?rev=1229439&r1=1229438&r2=1229439&view=diff
==============================================================================
---
labs/magnet/core/src/main/java/org/apache/labs/magnet/core/CoreRouteBuilder.java
(original)
+++
labs/magnet/core/src/main/java/org/apache/labs/magnet/core/CoreRouteBuilder.java
Tue Jan 10 01:29:53 2012
@@ -16,13 +16,15 @@
*/
package org.apache.labs.magnet.core;
-import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class CoreRouteBuilder extends RouteBuilder {
+ protected final transient Logger log =
LoggerFactory.getLogger(CoreRouteBuilder.class);
+
@Override
public void configure() throws Exception {
- from("direct:core").routeId("core").noAutoStartup()
- .setHeader(Exchange.FILE_NAME,
constant("filename")).to("log:core");
+ from("direct:ignore").routeId("ignore").to("mock:ignore");
}
}
Modified:
labs/magnet/core/src/test/java/org/apache/labs/magnet/core/RestServiceTest.java
URL:
http://svn.apache.org/viewvc/labs/magnet/core/src/test/java/org/apache/labs/magnet/core/RestServiceTest.java?rev=1229439&r1=1229438&r2=1229439&view=diff
==============================================================================
---
labs/magnet/core/src/test/java/org/apache/labs/magnet/core/RestServiceTest.java
(original)
+++
labs/magnet/core/src/test/java/org/apache/labs/magnet/core/RestServiceTest.java
Tue Jan 10 01:29:53 2012
@@ -33,7 +33,7 @@ public class RestServiceTest extends Cam
protected ClassPathXmlApplicationContext createApplicationContext() {
return new ClassPathXmlApplicationContext("META-INF/spring/beans.xml");
}
-
+
@Test
public void testAddBulletin() throws Exception {
HttpPost post = new HttpPost("http://localhost:9100/bbs";);
Modified: labs/magnet/magnet/pom.xml
URL:
http://svn.apache.org/viewvc/labs/magnet/magnet/pom.xml?rev=1229439&r1=1229438&r2=1229439&view=diff
==============================================================================
--- labs/magnet/magnet/pom.xml (original)
+++ labs/magnet/magnet/pom.xml Tue Jan 10 01:29:53 2012
@@ -114,6 +114,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-quartz</artifactId>
+ <version>${camel.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-test</artifactId>
<version>${camel.version}</version>
</dependency>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
