This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new acc2b2afd939 Remove usage of deprecated methods in langchain4j
acc2b2afd939 is described below
commit acc2b2afd93927b4443b73e3b9efc75036a1204f
Author: Aurélien Pupier <[email protected]>
AuthorDate: Fri Feb 6 15:35:41 2026 +0100
Remove usage of deprecated methods in langchain4j
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../LangChain4jEmbeddingsComponentMilvusTargetIT.java | 11 +++++++----
.../LangChain4jEmbeddingsComponentQdrantTargetIT.java | 15 ++++++++-------
.../component/milvus/MilvusCreateCollectionTest.java | 11 +++++++----
.../camel/component/milvus/it/MilvusComponentIT.java | 10 ++++++----
4 files changed, 28 insertions(+), 19 deletions(-)
diff --git
a/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentMilvusTargetIT.java
b/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentMilvusTargetIT.java
index bd7473053fb2..f47859e09deb 100644
---
a/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentMilvusTargetIT.java
+++
b/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentMilvusTargetIT.java
@@ -25,6 +25,7 @@ import io.milvus.common.clientenum.ConsistencyLevelEnum;
import io.milvus.grpc.DataType;
import io.milvus.param.IndexType;
import io.milvus.param.MetricType;
+import io.milvus.param.collection.CollectionSchemaParam;
import io.milvus.param.collection.CreateCollectionParam;
import io.milvus.param.collection.FieldType;
import io.milvus.param.highlevel.dml.SearchSimpleParam;
@@ -100,10 +101,12 @@ public class LangChain4jEmbeddingsComponentMilvusTargetIT
extends CamelTestSuppo
.withCollectionName("embeddings")
.withDescription("customer info")
.withShardsNum(2)
- .withEnableDynamicField(false)
- .addFieldType(fieldType1)
- .addFieldType(fieldType2)
- .addFieldType(fieldType3)
+ .withSchema(CollectionSchemaParam.newBuilder()
+ .withEnableDynamicField(false)
+ .addFieldType(fieldType1)
+ .addFieldType(fieldType2)
+ .addFieldType(fieldType3)
+ .build())
.build();
Exchange result = fluentTemplate.to(MILVUS_URI)
diff --git
a/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentQdrantTargetIT.java
b/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentQdrantTargetIT.java
index 1e9d3a0cdb81..42ed7e00efc5 100644
---
a/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentQdrantTargetIT.java
+++
b/components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsComponentQdrantTargetIT.java
@@ -29,6 +29,7 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.qdrant.Qdrant;
import org.apache.camel.component.qdrant.QdrantAction;
import org.apache.camel.component.qdrant.QdrantComponent;
+import org.apache.camel.component.qdrant.QdrantHeaders;
import org.apache.camel.spi.DataType;
import org.apache.camel.test.infra.qdrant.services.QdrantService;
import org.apache.camel.test.infra.qdrant.services.QdrantServiceFactory;
@@ -70,7 +71,7 @@ public class LangChain4jEmbeddingsComponentQdrantTargetIT
extends CamelTestSuppo
@Order(1)
public void createCollection() {
Exchange result = fluentTemplate.to(QDRANT_URI)
- .withHeader(Qdrant.Headers.ACTION,
QdrantAction.CREATE_COLLECTION)
+ .withHeader(QdrantHeaders.ACTION,
QdrantAction.CREATE_COLLECTION)
.withBody(
Collections.VectorParams.newBuilder()
.setSize(384)
@@ -96,7 +97,7 @@ public class LangChain4jEmbeddingsComponentQdrantTargetIT
extends CamelTestSuppo
@Order(3)
public void retrieve() {
Exchange result = fluentTemplate.to(QDRANT_URI)
- .withHeader(Qdrant.Headers.ACTION, QdrantAction.RETRIEVE)
+ .withHeader(QdrantHeaders.ACTION, QdrantAction.RETRIEVE)
.withBody(PointIdFactory.id(POINT_ID))
.request(Exchange.class);
@@ -126,8 +127,8 @@ public class LangChain4jEmbeddingsComponentQdrantTargetIT
extends CamelTestSuppo
public void configure() {
from("direct:in")
.to("langchain4j-embeddings:test")
-
.setHeader(Qdrant.Headers.ACTION).constant(QdrantAction.UPSERT)
- .setHeader(Qdrant.Headers.POINT_ID).constant(POINT_ID)
+
.setHeader(QdrantHeaders.ACTION).constant(QdrantAction.UPSERT)
+ .setHeader(QdrantHeaders.POINT_ID).constant(POINT_ID)
// transform data to embed to a vecto embeddings
.transformDataType(
new DataType("qdrant:embeddings"))
@@ -138,9 +139,9 @@ public class LangChain4jEmbeddingsComponentQdrantTargetIT
extends CamelTestSuppo
// transform prompt into embeddings for search
.transformDataType(
new DataType("qdrant:embeddings"))
- .setHeader(Qdrant.Headers.ACTION,
constant(QdrantAction.SIMILARITY_SEARCH))
- .setHeader(Qdrant.Headers.INCLUDE_VECTORS,
constant(true))
- .setHeader(Qdrant.Headers.INCLUDE_PAYLOAD,
constant(true))
+ .setHeader(QdrantHeaders.ACTION,
constant(QdrantAction.SIMILARITY_SEARCH))
+ .setHeader(QdrantHeaders.INCLUDE_VECTORS,
constant(true))
+ .setHeader(QdrantHeaders.INCLUDE_PAYLOAD,
constant(true))
.to(QDRANT_URI)
// decode retrieved embeddings for RAG
.transformDataType(
diff --git
a/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/MilvusCreateCollectionTest.java
b/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/MilvusCreateCollectionTest.java
index 10ed923f5d28..a75119addc33 100644
---
a/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/MilvusCreateCollectionTest.java
+++
b/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/MilvusCreateCollectionTest.java
@@ -18,6 +18,7 @@
package org.apache.camel.component.milvus;
import io.milvus.grpc.DataType;
+import io.milvus.param.collection.CollectionSchemaParam;
import io.milvus.param.collection.CreateCollectionParam;
import io.milvus.param.collection.FieldType;
import org.apache.camel.Exchange;
@@ -57,10 +58,12 @@ public class MilvusCreateCollectionTest extends
MilvusTestSupport {
.withCollectionName("test")
.withDescription("customer info")
.withShardsNum(2)
- .withEnableDynamicField(false)
- .addFieldType(fieldType1)
- .addFieldType(fieldType2)
- .addFieldType(fieldType3)
+ .withSchema(CollectionSchemaParam.newBuilder()
+ .withEnableDynamicField(false)
+ .addFieldType(fieldType1)
+ .addFieldType(fieldType2)
+ .addFieldType(fieldType3)
+ .build())
.build();
Exchange result = fluentTemplate.to("milvus:createCollection")
diff --git
a/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/it/MilvusComponentIT.java
b/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/it/MilvusComponentIT.java
index 6216796e112d..cab3064b0852 100644
---
a/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/it/MilvusComponentIT.java
+++
b/components/camel-ai/camel-milvus/src/test/java/org/apache/camel/component/milvus/it/MilvusComponentIT.java
@@ -25,6 +25,7 @@ import io.milvus.grpc.DataType;
import io.milvus.grpc.QueryResults;
import io.milvus.param.IndexType;
import io.milvus.param.MetricType;
+import io.milvus.param.collection.CollectionSchemaParam;
import io.milvus.param.collection.CreateCollectionParam;
import io.milvus.param.collection.FieldType;
import io.milvus.param.dml.DeleteParam;
@@ -73,10 +74,11 @@ public class MilvusComponentIT extends MilvusTestSupport {
.withCollectionName("test")
.withDescription("customer info")
.withShardsNum(2)
- .withEnableDynamicField(false)
- .addFieldType(fieldType1)
- .addFieldType(fieldType2)
- .addFieldType(fieldType3)
+ .withSchema(CollectionSchemaParam.newBuilder()
+ .withEnableDynamicField(false)
+ .addFieldType(fieldType1)
+ .addFieldType(fieldType2)
+ .addFieldType(fieldType3).build())
.build();
Exchange result = fluentTemplate.to("milvus:test")
