Author: davsclaus
Date: Fri Jun 4 15:38:35 2010
New Revision: 951451
URL: http://svn.apache.org/viewvc?rev=951451&view=rev
Log:
CAMEL-2537: Added option reverse on batch resequencer so you can resequence
JMSPriority messages and have 9..0 ordering. Only in batch mode.
Added:
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerJMSPriorityTest.java
- copied, changed from r951440,
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerAllowDuplicatesTest.java
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerJMSPriorityTest.xml
- copied, changed from r951440,
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerAllowDuplicatesTest.xml
Copied:
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerJMSPriorityTest.java
(from r951440,
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerAllowDuplicatesTest.java)
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerJMSPriorityTest.java?p2=camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerJMSPriorityTest.java&p1=camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerAllowDuplicatesTest.java&r1=951440&r2=951451&rev=951451&view=diff
==============================================================================
---
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerAllowDuplicatesTest.java
(original)
+++
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringBatchResequencerJMSPriorityTest.java
Fri Jun 4 15:38:35 2010
@@ -17,16 +17,16 @@
package org.apache.camel.spring.processor;
import org.apache.camel.CamelContext;
-import org.apache.camel.processor.BatchResequencerAllowDuplicatesTest;
+import org.apache.camel.processor.BatchResequencerJMSPriorityTest;
import static
org.apache.camel.spring.processor.SpringTestHelper.createSpringCamelContext;
/**
* @version $Revision$
*/
-public class SpringBatchResequencerAllowDuplicatesTest extends
BatchResequencerAllowDuplicatesTest {
+public class SpringBatchResequencerJMSPriorityTest extends
BatchResequencerJMSPriorityTest {
protected CamelContext createCamelContext() throws Exception {
- return createSpringCamelContext(this,
"org/apache/camel/spring/processor/BatchResequencerAllowDuplicatesTest.xml");
+ return createSpringCamelContext(this,
"org/apache/camel/spring/processor/BatchResequencerJMSPriorityTest.xml");
}
}
\ No newline at end of file
Copied:
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerJMSPriorityTest.xml
(from r951440,
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerAllowDuplicatesTest.xml)
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerJMSPriorityTest.xml?p2=camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerJMSPriorityTest.xml&p1=camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerAllowDuplicatesTest.xml&r1=951440&r2=951451&rev=951451&view=diff
==============================================================================
---
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerAllowDuplicatesTest.xml
(original)
+++
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/BatchResequencerJMSPriorityTest.xml
Fri Jun 4 15:38:35 2010
@@ -27,9 +27,13 @@
<route>
<from uri="direct:start"/>
<resequence>
- <header>id</header>
+ <header>JMSPriority</header>
<to uri="mock:result"/>
- <batch-config allowDuplicates="true"/>
+<!--
+ // sort by JMSPriority by allowing duplicates (message can
have same JMSPriority)
+ // and use reverse ordering so 9 is first output (most
important), and 0 is last
+-->
+ <batch-config allowDuplicates="true" reverse="true"/>
</resequence>
</route>
</camelContext>
