svn commit: r642203 - in /activemq/camel/trunk/components/camel-bam/src: main/java/org/apache/camel/bam/processor/ test/java/org/apache/camel/bam/
Date: Fri Mar 28 04:27:18 2008
New Revision: 642203
URL: http://svn.apache.org/viewvc?rev=642203&view=rev Log:
- fixed concurrency issue with creating a new entity. Now using a ReentrantLock from Java.
- no more exceptions in the camel-bam-example demo app as well.
- added some assertions to the unit test
+ // it was b that was the problem and thus send to the overdue endpoint
+ ActivityState state = overdueEndpoint.getExchanges().get(0).getIn().getBody(ActivityState.class);
+ assertEquals("123", state.getCorrelationKey());
+ assertEquals("b", state.getActivityDefinition().getName());