You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/09/21 17:27:04 UTC
svn commit: r817289 - in /camel/trunk:
camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java
Author: davsclaus
Date: Mon Sep 21 15:26:59 2009
New Revision: 817289
URL: http://svn.apache.org/viewvc?rev=817289&view=rev
Log:
Fixed jpa unit test failure and improved mock failure message.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java?rev=817289&r1=817288&r2=817289&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java Mon Sep 21 15:26:59 2009
@@ -893,7 +893,7 @@
List<Exchange> list = getReceivedExchanges();
int index = 0;
for (Exchange exchange : list) {
- LOG.debug("Received[" + (++index) + "]: " + exchange);
+ LOG.debug(getEndpointUri() + " failed and received[" + (++index) + "]: " + exchange);
}
}
throw new AssertionError(getEndpointUri() + " " + message);
Modified: camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java?rev=817289&r1=817288&r2=817289&view=diff
==============================================================================
--- camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java (original)
+++ camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/JpaIdempotentConsumerTest.java Mon Sep 21 15:26:59 2009
@@ -17,6 +17,8 @@
package org.apache.camel.processor.jpa;
import java.util.List;
+import java.util.Set;
+import java.util.HashSet;
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
@@ -118,6 +120,18 @@
sendMessage("3", "three");
assertMockEndpointsSatisfied();
+
+ // all 3 messages should be in jpa repo
+ Set<String> ids = new HashSet<String>();
+ List<MessageProcessed> list = jpaTemplate.find(SELECT_ALL_STRING, PROCESSOR_NAME);
+ for (MessageProcessed item : list) {
+ ids.add(item.getMessageId());
+ }
+
+ assertEquals(3, ids.size());
+ assertTrue("Should contain message 1", ids.contains("1"));
+ assertTrue("Should contain message 2", ids.contains("2"));
+ assertTrue("Should contain message 3", ids.contains("3"));
}
@Test
@@ -125,7 +139,7 @@
context.addRoutes(new SpringRouteBuilder() {
@Override
public void configure() throws Exception {
- errorHandler(deadLetterChannel("mock:error").maximumRedeliveries(2).redeliverDelay(0).logStackTrace(false).handled(false));
+ errorHandler(deadLetterChannel("mock:error").maximumRedeliveries(0).redeliverDelay(0).logStackTrace(false));
from("direct:start").idempotentConsumer(
header("messageId"),
@@ -134,7 +148,7 @@
public void process(Exchange exchange) throws Exception {
String id = exchange.getIn().getHeader("messageId", String.class);
if (id.equals("2")) {
- throw new IllegalArgumentException("Damm I cannot handle id 2");
+ throw new IllegalArgumentException("Damn I cannot handle id 2");
}
}
}).to("mock:result");
@@ -154,6 +168,17 @@
sendMessage("3", "three");
assertMockEndpointsSatisfied();
+
+ // only message 1 and 3 should be in jpa repo
+ Set<String> ids = new HashSet<String>();
+ List<MessageProcessed> list = jpaTemplate.find(SELECT_ALL_STRING, PROCESSOR_NAME);
+ for (MessageProcessed item : list) {
+ ids.add(item.getMessageId());
+ }
+
+ assertEquals(2, ids.size());
+ assertTrue("Should contain message 1", ids.contains("1"));
+ assertTrue("Should contain message 3", ids.contains("3"));
}
protected void sendMessage(final Object messageId, final Object body) {