BATCHEE-160 move back to old Camel version
Had to revert to the ancient camel version as this test was just broken.
If someone else with better Camel knowledge could please assist?
diff --git a/extensions/camel/pom.xml b/extensions/camel/pom.xml
index 2ade2c4..e8ceea6 100644
--- a/extensions/camel/pom.xml
+++ b/extensions/camel/pom.xml
@@ -54,6 +54,6 @@
</dependencies>
<properties>
- <camel.version>2.25.4</camel.version>
+ <camel.version>2.11.1</camel.version>
</properties>
</project>
diff --git a/extensions/camel/src/test/java/org/apache/batchee/camel/CamelReaderTest.java b/extensions/camel/src/test/java/org/apache/batchee/camel/CamelReaderTest.java
index 8f47aef..b5f0e07 100644
--- a/extensions/camel/src/test/java/org/apache/batchee/camel/CamelReaderTest.java
+++ b/extensions/camel/src/test/java/org/apache/batchee/camel/CamelReaderTest.java
@@ -19,7 +19,6 @@
import org.apache.batchee.util.Batches;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.component.direct.DirectEndpoint;
-import org.apache.camel.component.directvm.DirectVmEndpoint;
import org.testng.annotations.Test;
import jakarta.batch.api.chunk.ItemProcessor;
@@ -40,7 +39,7 @@
final long id = jobOperator.start("camel-reader", new Properties());
- while (DirectVmEndpoint.class.cast(CamelBridge.CONTEXT.getEndpoint("direct:reader")).getConsumer() == null) {
+ while (DirectEndpoint.class.cast(CamelBridge.CONTEXT.getEndpoint("direct:reader")).getConsumer() == null) {
Thread.sleep(100);
}
diff --git a/extensions/camel/src/test/java/org/apache/batchee/camel/CamelWriterTest.java b/extensions/camel/src/test/java/org/apache/batchee/camel/CamelWriterTest.java
index 57799eb..a54d904 100644
--- a/extensions/camel/src/test/java/org/apache/batchee/camel/CamelWriterTest.java
+++ b/extensions/camel/src/test/java/org/apache/batchee/camel/CamelWriterTest.java
@@ -19,7 +19,6 @@
import org.apache.batchee.util.Batches;
import org.apache.camel.ConsumerTemplate;
import org.apache.camel.component.direct.DirectEndpoint;
-import org.apache.camel.component.directvm.DirectVmEndpoint;
import org.testng.annotations.Test;
import jakarta.batch.api.chunk.ItemReader;
@@ -54,7 +53,7 @@
do { // starting the listener in another thread w can get timing issues so ensuring we are in the right state
Thread.sleep(20);
- } while (DirectVmEndpoint.class.cast(CamelBridge.CONTEXT.getEndpoint("direct:writer")).getConsumer() == null);
+ } while (DirectEndpoint.class.cast(CamelBridge.CONTEXT.getEndpoint("direct:writer")).getConsumer() == null);
final JobOperator jobOperator = BatchRuntime.getJobOperator();
Batches.waitForEnd(jobOperator, jobOperator.start("camel-writer", new Properties()));
