You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2007/04/20 13:59:46 UTC
svn commit: r530755 - in /activemq/camel/trunk:
camel-core/src/test/java/org/apache/camel/
camel-core/src/test/java/org/apache/camel/processor/
camel-jpa/src/test/java/org/apache/camel/processor/jpa/
Author: jstrachan
Date: Fri Apr 20 04:59:45 2007
New Revision: 530755
URL: http://svn.apache.org/viewvc?view=rev&rev=530755
Log:
fixed failing test case
Modified:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerTest.java
activemq/camel/trunk/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java
Modified: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java?view=diff&rev=530755&r1=530754&r2=530755
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java (original)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/ContextTestSupport.java Fri Apr 20 04:59:45 2007
@@ -49,7 +49,7 @@
context.stop();
}
- protected CamelContext createCamelContext() {
+ protected CamelContext createCamelContext() throws Exception {
return new DefaultCamelContext();
}
Modified: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerTest.java?view=diff&rev=530755&r1=530754&r2=530755
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerTest.java (original)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/IdempotentConsumerTest.java Fri Apr 20 04:59:45 2007
@@ -71,14 +71,14 @@
protected void setUp() throws Exception {
super.setUp();
- startEndpoint = resolveMandatoryEndpoint("direct:test.a");
+ startEndpoint = resolveMandatoryEndpoint("direct:start");
resultEndpoint = (MockEndpoint) resolveMandatoryEndpoint("mock:result");
}
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- from("direct:test.a").idempotentConsumer(header("messageId"), memoryMessageIdRepository()).to("mock:result");
+ from("direct:start").idempotentConsumer(header("messageId"), memoryMessageIdRepository()).to("mock:result");
}
};
}
Modified: activemq/camel/trunk/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java?view=diff&rev=530755&r1=530754&r2=530755
==============================================================================
--- activemq/camel/trunk/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java (original)
+++ activemq/camel/trunk/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java Fri Apr 20 04:59:45 2007
@@ -36,20 +36,20 @@
protected ApplicationContext applicationContext;
@Override
- protected CamelContext createContext() throws Exception {
+ protected CamelContext createCamelContext() throws Exception {
applicationContext = new ClassPathXmlApplicationContext("org/apache/camel/processor/jpa/spring.xml");
return SpringCamelContext.springCamelContext(applicationContext);
}
@Override
- protected RouteBuilder createRouteBuilder(final String fromUri, final String toUri) {
+ protected RouteBuilder createRouteBuilder() {
// START SNIPPET: idempotent
return new SpringRouteBuilder<Exchange>() {
public void configure() {
- from(fromUri).idempotentConsumer(
+ from("direct:start").idempotentConsumer(
header("messageId"),
jpaMessageIdRepository(bean(JpaTemplate.class), "myProcessorName")
- ).to(toUri);
+ ).to("mock:result");
}
};
// END SNIPPET: idempotent