This is an automated email from the ASF dual-hosted git repository.
fmariani 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 bd42be7d220c Improve langchain4j embeddings documentation +
ReturnTextContent option for the embeddingstore
bd42be7d220c is described below
commit bd42be7d220cd8e124c1eea4c96f0ecc8610b90d
Author: Croway <[email protected]>
AuthorDate: Fri Jan 23 14:39:42 2026 +0100
Improve langchain4j embeddings documentation + ReturnTextContent option for
the embeddingstore
---
.../components/langchain4j-embeddingstore.json | 24 ++-
.../docs/langchain4j-embeddings-component.adoc | 124 +++++++++++++++
...ngChain4jEmbeddingStoreComponentConfigurer.java | 21 +++
...ain4jEmbeddingStoreConfigurationConfigurer.java | 21 +++
...angChain4jEmbeddingStoreEndpointConfigurer.java | 21 +++
...angChain4jEmbeddingStoreEndpointUriFactory.java | 6 +-
.../embeddingstore/langchain4j-embeddingstore.json | 24 ++-
.../docs/langchain4j-embeddingstore-component.adoc | 174 +++++++++++++++++++++
.../LangChain4jEmbeddingStoreConfiguration.java | 45 ++++++
.../LangChain4jEmbeddingStoreProducer.java | 53 +++++--
...ain4jEmbeddingStoreComponentQdrantTargetIT.java | 51 ++++++
...ain4jEmbeddingstoreComponentBuilderFactory.java | 69 ++++++++
...hain4jEmbeddingStoreEndpointBuilderFactory.java | 119 ++++++++++++++
13 files changed, 719 insertions(+), 33 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/langchain4j-embeddingstore.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/langchain4j-embeddingstore.json
index 433567936f93..c00617d353f4 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/langchain4j-embeddingstore.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/langchain4j-embeddingstore.json
@@ -24,11 +24,15 @@
"remote": true
},
"componentProperties": {
- "configuration": { "index": 0, "kind": "property", "displayName":
"Configuration", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
configuration;" },
- "embeddingStore": { "index": 1, "kind": "property", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "config [...]
- "embeddingStoreFactory": { "index": 2, "kind": "property", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "conf [...]
- "lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
- "autowiredEnabled": { "index": 4, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
+ "action": { "index": 0, "kind": "property", "displayName": "Action",
"group": "producer", "label": "", "required": false, "type": "enum",
"javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction",
"enum": [ "ADD", "REMOVE", "SEARCH" ], "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configurati [...]
+ "configuration": { "index": 1, "kind": "property", "displayName":
"Configuration", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
configuration;" },
+ "embeddingStore": { "index": 2, "kind": "property", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "config [...]
+ "embeddingStoreFactory": { "index": 3, "kind": "property", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "conf [...]
+ "lazyStartProducer": { "index": 4, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
+ "maxResults": { "index": 5, "kind": "property", "displayName": "Max
Results", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 5, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Maximum number of
results to return for SEARCH operation" },
+ "minScore": { "index": 6, "kind": "property", "displayName": "Min Score",
"group": "producer", "label": "", "required": false, "type": "number",
"javaType": "java.lang.Double", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Minimum similarity
score threshold for SEARCH operation (0.0 to 1.0)" },
+ "returnTextContent": { "index": 7, "kind": "property", "displayName":
"Return Text Content", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "When true, SEARCH
returns List with text conte [...]
+ "autowiredEnabled": { "index": 8, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
},
"headers": {
"CamelLangchain4jEmbeddingStoreAction": { "index": 0, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "String", "enum": [ "ADD", "REMOVE", "SEARCH" ], "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "The action to be performed.", "constantName":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreHeaders#ACTION"
},
@@ -38,8 +42,12 @@
},
"properties": {
"embeddingStoreId": { "index": 0, "kind": "path", "displayName":
"Embedding Store Id", "group": "producer", "label": "", "required": true,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
id of the embedding store" },
- "embeddingStore": { "index": 1, "kind": "parameter", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "confi [...]
- "embeddingStoreFactory": { "index": 2, "kind": "parameter", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "con [...]
- "lazyStartProducer": { "index": 3, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produc [...]
+ "action": { "index": 1, "kind": "parameter", "displayName": "Action",
"group": "producer", "label": "", "required": false, "type": "enum",
"javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction",
"enum": [ "ADD", "REMOVE", "SEARCH" ], "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configurat [...]
+ "embeddingStore": { "index": 2, "kind": "parameter", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "confi [...]
+ "embeddingStoreFactory": { "index": 3, "kind": "parameter", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "con [...]
+ "maxResults": { "index": 4, "kind": "parameter", "displayName": "Max
Results", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 5, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Maximum number of
results to return for SEARCH operation" },
+ "minScore": { "index": 5, "kind": "parameter", "displayName": "Min Score",
"group": "producer", "label": "", "required": false, "type": "number",
"javaType": "java.lang.Double", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Minimum similarity
score threshold for SEARCH operation (0.0 to 1.0)" },
+ "returnTextContent": { "index": 6, "kind": "parameter", "displayName":
"Return Text Content", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "When true, SEARCH
returns List with text cont [...]
+ "lazyStartProducer": { "index": 7, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produc [...]
}
}
diff --git
a/components/camel-ai/camel-langchain4j-embeddings/src/main/docs/langchain4j-embeddings-component.adoc
b/components/camel-ai/camel-langchain4j-embeddings/src/main/docs/langchain4j-embeddings-component.adoc
index 3003058387e4..8d6606d071d9 100644
---
a/components/camel-ai/camel-langchain4j-embeddings/src/main/docs/langchain4j-embeddings-component.adoc
+++
b/components/camel-ai/camel-langchain4j-embeddings/src/main/docs/langchain4j-embeddings-component.adoc
@@ -182,3 +182,127 @@ YAML::
embeddingModel: "#myEmbeddingModel"
----
====
+
+=== Integration with Vector Stores
+
+The LangChain4j Embeddings component works seamlessly with vector databases
for RAG (Retrieval-Augmented Generation) workflows.
+
+==== Using with Qdrant
+
+This example shows how to embed text and store it in Qdrant vector database:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:store")
+ .to("langchain4j-embeddings:embed")
+ .setHeader(Qdrant.Headers.ACTION).constant(QdrantAction.UPSERT)
+ .setHeader(Qdrant.Headers.POINT_ID).constant(1)
+ .transformDataType(new DataType("qdrant:embeddings"))
+ .to("qdrant:myCollection");
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:store"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - setHeader:
+ name: CamelQdrantAction
+ constant: UPSERT
+ - setHeader:
+ name: CamelQdrantPointId
+ constant: 1
+ - transform:
+ dataType: "qdrant:embeddings"
+ - to: "qdrant:myCollection"
+----
+====
+
+==== Similarity Search for RAG
+
+Retrieve relevant content using similarity search:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:search")
+ .to("langchain4j-embeddings:embed")
+ .transformDataType(new DataType("qdrant:embeddings"))
+ .setHeader(Qdrant.Headers.ACTION, constant(QdrantAction.SIMILARITY_SEARCH))
+ .setHeader(Qdrant.Headers.INCLUDE_PAYLOAD, constant(true))
+ .to("qdrant:myCollection")
+ .transformDataType(new DataType("qdrant:rag"));
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:search"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - transform:
+ dataType: "qdrant:embeddings"
+ - setHeader:
+ name: CamelQdrantAction
+ constant: SIMILARITY_SEARCH
+ - setHeader:
+ name: CamelQdrantIncludePayload
+ constant: true
+ - to: "qdrant:myCollection"
+ - transform:
+ dataType: "qdrant:rag"
+----
+====
+
+==== Using with LangChain4j Embedding Store Component
+
+For a simpler integration, use the `langchain4j-embeddingstore` component
which provides a unified interface:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:store")
+ .to("langchain4j-embeddings:embed")
+ .to("langchain4j-embeddingstore:myStore?action=ADD");
+
+from("direct:search")
+ .to("langchain4j-embeddings:embed")
+
.to("langchain4j-embeddingstore:myStore?action=SEARCH&maxResults=5&returnTextContent=true");
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:store"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - to: "langchain4j-embeddingstore:myStore?action=ADD"
+
+- route:
+ from:
+ uri: "direct:search"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - to:
"langchain4j-embeddingstore:myStore?action=SEARCH&maxResults=5&returnTextContent=true"
+----
+====
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreComponentConfigurer.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreComponentConfigurer.java
index 9078ca043429..e9514aede8b5 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreComponentConfigurer.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreComponentConfigurer.java
@@ -30,6 +30,7 @@ public class LangChain4jEmbeddingStoreComponentConfigurer
extends PropertyConfig
public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
LangChain4jEmbeddingStoreComponent target =
(LangChain4jEmbeddingStoreComponent) obj;
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action":
getOrCreateConfiguration(target).setAction(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction.class,
value)); return true;
case "autowiredenabled":
case "autowiredEnabled":
target.setAutowiredEnabled(property(camelContext, boolean.class, value));
return true;
case "configuration": target.setConfiguration(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration.class,
value)); return true;
@@ -39,6 +40,12 @@ public class LangChain4jEmbeddingStoreComponentConfigurer
extends PropertyConfig
case "embeddingStoreFactory":
getOrCreateConfiguration(target).setEmbeddingStoreFactory(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory.class,
value)); return true;
case "lazystartproducer":
case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
+ case "maxresults":
+ case "maxResults":
getOrCreateConfiguration(target).setMaxResults(property(camelContext,
java.lang.Integer.class, value)); return true;
+ case "minscore":
+ case "minScore":
getOrCreateConfiguration(target).setMinScore(property(camelContext,
java.lang.Double.class, value)); return true;
+ case "returntextcontent":
+ case "returnTextContent":
getOrCreateConfiguration(target).setReturnTextContent(property(camelContext,
boolean.class, value)); return true;
default: return false;
}
}
@@ -51,6 +58,7 @@ public class LangChain4jEmbeddingStoreComponentConfigurer
extends PropertyConfig
@Override
public Class<?> getOptionType(String name, boolean ignoreCase) {
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": return
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction.class;
case "autowiredenabled":
case "autowiredEnabled": return boolean.class;
case "configuration": return
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration.class;
@@ -60,6 +68,12 @@ public class LangChain4jEmbeddingStoreComponentConfigurer
extends PropertyConfig
case "embeddingStoreFactory": return
org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory.class;
case "lazystartproducer":
case "lazyStartProducer": return boolean.class;
+ case "maxresults":
+ case "maxResults": return java.lang.Integer.class;
+ case "minscore":
+ case "minScore": return java.lang.Double.class;
+ case "returntextcontent":
+ case "returnTextContent": return boolean.class;
default: return null;
}
}
@@ -68,6 +82,7 @@ public class LangChain4jEmbeddingStoreComponentConfigurer
extends PropertyConfig
public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
LangChain4jEmbeddingStoreComponent target =
(LangChain4jEmbeddingStoreComponent) obj;
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": return getOrCreateConfiguration(target).getAction();
case "autowiredenabled":
case "autowiredEnabled": return target.isAutowiredEnabled();
case "configuration": return target.getConfiguration();
@@ -77,6 +92,12 @@ public class LangChain4jEmbeddingStoreComponentConfigurer
extends PropertyConfig
case "embeddingStoreFactory": return
getOrCreateConfiguration(target).getEmbeddingStoreFactory();
case "lazystartproducer":
case "lazyStartProducer": return target.isLazyStartProducer();
+ case "maxresults":
+ case "maxResults": return
getOrCreateConfiguration(target).getMaxResults();
+ case "minscore":
+ case "minScore": return getOrCreateConfiguration(target).getMinScore();
+ case "returntextcontent":
+ case "returnTextContent": return
getOrCreateConfiguration(target).isReturnTextContent();
default: return null;
}
}
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfigurationConfigurer.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfigurationConfigurer.java
index 883c7249bcf9..23be327bc30e 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfigurationConfigurer.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfigurationConfigurer.java
@@ -23,10 +23,17 @@ public class
LangChain4jEmbeddingStoreConfigurationConfigurer extends org.apache
public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration
target =
(org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration)
obj;
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": target.setAction(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction.class,
value)); return true;
case "embeddingstore":
case "embeddingStore": target.setEmbeddingStore(property(camelContext,
dev.langchain4j.store.embedding.EmbeddingStore.class, value)); return true;
case "embeddingstorefactory":
case "embeddingStoreFactory":
target.setEmbeddingStoreFactory(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory.class,
value)); return true;
+ case "maxresults":
+ case "maxResults": target.setMaxResults(property(camelContext,
java.lang.Integer.class, value)); return true;
+ case "minscore":
+ case "minScore": target.setMinScore(property(camelContext,
java.lang.Double.class, value)); return true;
+ case "returntextcontent":
+ case "returnTextContent":
target.setReturnTextContent(property(camelContext, boolean.class, value));
return true;
default: return false;
}
}
@@ -34,10 +41,17 @@ public class
LangChain4jEmbeddingStoreConfigurationConfigurer extends org.apache
@Override
public Class<?> getOptionType(String name, boolean ignoreCase) {
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": return
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction.class;
case "embeddingstore":
case "embeddingStore": return
dev.langchain4j.store.embedding.EmbeddingStore.class;
case "embeddingstorefactory":
case "embeddingStoreFactory": return
org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory.class;
+ case "maxresults":
+ case "maxResults": return java.lang.Integer.class;
+ case "minscore":
+ case "minScore": return java.lang.Double.class;
+ case "returntextcontent":
+ case "returnTextContent": return boolean.class;
default: return null;
}
}
@@ -46,10 +60,17 @@ public class
LangChain4jEmbeddingStoreConfigurationConfigurer extends org.apache
public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration
target =
(org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration)
obj;
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": return target.getAction();
case "embeddingstore":
case "embeddingStore": return target.getEmbeddingStore();
case "embeddingstorefactory":
case "embeddingStoreFactory": return target.getEmbeddingStoreFactory();
+ case "maxresults":
+ case "maxResults": return target.getMaxResults();
+ case "minscore":
+ case "minScore": return target.getMinScore();
+ case "returntextcontent":
+ case "returnTextContent": return target.isReturnTextContent();
default: return null;
}
}
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointConfigurer.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointConfigurer.java
index cb76e8ab0428..f90f9ac8fc73 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointConfigurer.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointConfigurer.java
@@ -23,12 +23,19 @@ public class LangChain4jEmbeddingStoreEndpointConfigurer
extends PropertyConfigu
public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
LangChain4jEmbeddingStoreEndpoint target =
(LangChain4jEmbeddingStoreEndpoint) obj;
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action":
target.getConfiguration().setAction(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction.class,
value)); return true;
case "embeddingstore":
case "embeddingStore":
target.getConfiguration().setEmbeddingStore(property(camelContext,
dev.langchain4j.store.embedding.EmbeddingStore.class, value)); return true;
case "embeddingstorefactory":
case "embeddingStoreFactory":
target.getConfiguration().setEmbeddingStoreFactory(property(camelContext,
org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory.class,
value)); return true;
case "lazystartproducer":
case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
+ case "maxresults":
+ case "maxResults":
target.getConfiguration().setMaxResults(property(camelContext,
java.lang.Integer.class, value)); return true;
+ case "minscore":
+ case "minScore":
target.getConfiguration().setMinScore(property(camelContext,
java.lang.Double.class, value)); return true;
+ case "returntextcontent":
+ case "returnTextContent":
target.getConfiguration().setReturnTextContent(property(camelContext,
boolean.class, value)); return true;
default: return false;
}
}
@@ -41,12 +48,19 @@ public class LangChain4jEmbeddingStoreEndpointConfigurer
extends PropertyConfigu
@Override
public Class<?> getOptionType(String name, boolean ignoreCase) {
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": return
org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction.class;
case "embeddingstore":
case "embeddingStore": return
dev.langchain4j.store.embedding.EmbeddingStore.class;
case "embeddingstorefactory":
case "embeddingStoreFactory": return
org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory.class;
case "lazystartproducer":
case "lazyStartProducer": return boolean.class;
+ case "maxresults":
+ case "maxResults": return java.lang.Integer.class;
+ case "minscore":
+ case "minScore": return java.lang.Double.class;
+ case "returntextcontent":
+ case "returnTextContent": return boolean.class;
default: return null;
}
}
@@ -55,12 +69,19 @@ public class LangChain4jEmbeddingStoreEndpointConfigurer
extends PropertyConfigu
public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
LangChain4jEmbeddingStoreEndpoint target =
(LangChain4jEmbeddingStoreEndpoint) obj;
switch (ignoreCase ? name.toLowerCase() : name) {
+ case "action": return target.getConfiguration().getAction();
case "embeddingstore":
case "embeddingStore": return
target.getConfiguration().getEmbeddingStore();
case "embeddingstorefactory":
case "embeddingStoreFactory": return
target.getConfiguration().getEmbeddingStoreFactory();
case "lazystartproducer":
case "lazyStartProducer": return target.isLazyStartProducer();
+ case "maxresults":
+ case "maxResults": return target.getConfiguration().getMaxResults();
+ case "minscore":
+ case "minScore": return target.getConfiguration().getMinScore();
+ case "returntextcontent":
+ case "returnTextContent": return
target.getConfiguration().isReturnTextContent();
default: return null;
}
}
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointUriFactory.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointUriFactory.java
index 61e191670e26..43a64a334e22 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointUriFactory.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreEndpointUriFactory.java
@@ -23,11 +23,15 @@ public class LangChain4jEmbeddingStoreEndpointUriFactory
extends org.apache.came
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Map<String, String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(4);
+ Set<String> props = new HashSet<>(8);
+ props.add("action");
props.add("embeddingStore");
props.add("embeddingStoreFactory");
props.add("embeddingStoreId");
props.add("lazyStartProducer");
+ props.add("maxResults");
+ props.add("minScore");
+ props.add("returnTextContent");
PROPERTY_NAMES = Collections.unmodifiableSet(props);
SECRET_PROPERTY_NAMES = Collections.emptySet();
MULTI_VALUE_PREFIXES = Collections.emptyMap();
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/resources/META-INF/org/apache/camel/component/langchain4j/embeddingstore/langchain4j-embeddingstore.json
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/resources/META-INF/org/apache/camel/component/langchain4j/embeddingstore/langchain4j-embeddingstore.json
index 433567936f93..c00617d353f4 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/resources/META-INF/org/apache/camel/component/langchain4j/embeddingstore/langchain4j-embeddingstore.json
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/generated/resources/META-INF/org/apache/camel/component/langchain4j/embeddingstore/langchain4j-embeddingstore.json
@@ -24,11 +24,15 @@
"remote": true
},
"componentProperties": {
- "configuration": { "index": 0, "kind": "property", "displayName":
"Configuration", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
configuration;" },
- "embeddingStore": { "index": 1, "kind": "property", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "config [...]
- "embeddingStoreFactory": { "index": 2, "kind": "property", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "conf [...]
- "lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
- "autowiredEnabled": { "index": 4, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
+ "action": { "index": 0, "kind": "property", "displayName": "Action",
"group": "producer", "label": "", "required": false, "type": "enum",
"javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction",
"enum": [ "ADD", "REMOVE", "SEARCH" ], "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configurati [...]
+ "configuration": { "index": 1, "kind": "property", "displayName":
"Configuration", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
configuration;" },
+ "embeddingStore": { "index": 2, "kind": "property", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "config [...]
+ "embeddingStoreFactory": { "index": 3, "kind": "property", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "conf [...]
+ "lazyStartProducer": { "index": 4, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
+ "maxResults": { "index": 5, "kind": "property", "displayName": "Max
Results", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 5, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Maximum number of
results to return for SEARCH operation" },
+ "minScore": { "index": 6, "kind": "property", "displayName": "Min Score",
"group": "producer", "label": "", "required": false, "type": "number",
"javaType": "java.lang.Double", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Minimum similarity
score threshold for SEARCH operation (0.0 to 1.0)" },
+ "returnTextContent": { "index": 7, "kind": "property", "displayName":
"Return Text Content", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "When true, SEARCH
returns List with text conte [...]
+ "autowiredEnabled": { "index": 8, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
},
"headers": {
"CamelLangchain4jEmbeddingStoreAction": { "index": 0, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "String", "enum": [ "ADD", "REMOVE", "SEARCH" ], "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "The action to be performed.", "constantName":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreHeaders#ACTION"
},
@@ -38,8 +42,12 @@
},
"properties": {
"embeddingStoreId": { "index": 0, "kind": "path", "displayName":
"Embedding Store Id", "group": "producer", "label": "", "required": true,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
id of the embedding store" },
- "embeddingStore": { "index": 1, "kind": "parameter", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "confi [...]
- "embeddingStoreFactory": { "index": 2, "kind": "parameter", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "con [...]
- "lazyStartProducer": { "index": 3, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produc [...]
+ "action": { "index": 1, "kind": "parameter", "displayName": "Action",
"group": "producer", "label": "", "required": false, "type": "enum",
"javaType":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction",
"enum": [ "ADD", "REMOVE", "SEARCH" ], "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configurat [...]
+ "embeddingStore": { "index": 2, "kind": "parameter", "displayName":
"Embedding Store", "group": "producer", "label": "", "required": false, "type":
"object", "javaType":
"dev.langchain4j.store.embedding.EmbeddingStore<dev.langchain4j.data.segment.TextSegment>",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret":
false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "confi [...]
+ "embeddingStoreFactory": { "index": 3, "kind": "parameter", "displayName":
"Embedding Store Factory", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "con [...]
+ "maxResults": { "index": 4, "kind": "parameter", "displayName": "Max
Results", "group": "producer", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 5, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Maximum number of
results to return for SEARCH operation" },
+ "minScore": { "index": 5, "kind": "parameter", "displayName": "Min Score",
"group": "producer", "label": "", "required": false, "type": "number",
"javaType": "java.lang.Double", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "Minimum similarity
score threshold for SEARCH operation (0.0 to 1.0)" },
+ "returnTextContent": { "index": 6, "kind": "parameter", "displayName":
"Return Text Content", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration",
"configurationField": "configuration", "description": "When true, SEARCH
returns List with text cont [...]
+ "lazyStartProducer": { "index": 7, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produc [...]
}
}
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/main/docs/langchain4j-embeddingstore-component.adoc
b/components/camel-ai/camel-langchain4j-embeddingstore/src/main/docs/langchain4j-embeddingstore-component.adoc
index 794ef6c07648..7b83aa94cc9e 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/main/docs/langchain4j-embeddingstore-component.adoc
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/main/docs/langchain4j-embeddingstore-component.adoc
@@ -51,3 +51,177 @@ include::partial$component-endpoint-headers.adoc[]
// component options: END
include::spring-boot:partial$starter.adoc[]
+
+== Usage
+
+=== Configuring an Embedding Store
+
+The component requires an `EmbeddingStore` instance. Register it in the Camel
registry:
+
+[source,java]
+----
+EmbeddingStore<TextSegment> embeddingStore = PgVectorEmbeddingStore.builder()
+ .host("localhost")
+ .port(5432)
+ .database("vectordb")
+ .user("postgres")
+ .password("postgres")
+ .table("embeddings")
+ .dimension(384)
+ .build();
+
+context.getRegistry().bind("myEmbeddingStore", embeddingStore);
+----
+
+=== Storing Embeddings (ADD Operation)
+
+Store embeddings with optional text segments:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:store")
+ .to("langchain4j-embeddings:embed")
+ .to("langchain4j-embeddingstore:myStore?action=ADD");
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:store"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - to: "langchain4j-embeddingstore:myStore?action=ADD"
+----
+====
+
+The response body contains the generated embedding ID.
+
+=== Searching Embeddings (SEARCH Operation)
+
+Perform similarity search to find relevant content:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:search")
+ .to("langchain4j-embeddings:embed")
+
.to("langchain4j-embeddingstore:myStore?action=SEARCH&maxResults=5&minScore=0.7");
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:search"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - to:
"langchain4j-embeddingstore:myStore?action=SEARCH&maxResults=5&minScore=0.7"
+----
+====
+
+The response contains a list of `EmbeddingMatch` objects with the matching
text segments and scores.
+
+==== Returning Text Content Directly
+
+Use the `returnTextContent` option to get a list of strings instead of
`EmbeddingMatch` objects:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:search")
+ .to("langchain4j-embeddings:embed")
+
.to("langchain4j-embeddingstore:myStore?action=SEARCH&maxResults=5&returnTextContent=true")
+ .log("Found texts: ${body}");
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:search"
+ steps:
+ - to: "langchain4j-embeddings:embed"
+ - to:
"langchain4j-embeddingstore:myStore?action=SEARCH&maxResults=5&returnTextContent=true"
+ - log: "Found texts: ${body}"
+----
+====
+
+=== Removing Embeddings (REMOVE Operation)
+
+Delete embeddings by their ID:
+
+[tabs]
+====
+Java::
++
+[source,java]
+----
+from("direct:remove")
+ .setBody(simple("${header.embeddingId}"))
+ .to("langchain4j-embeddingstore:myStore?action=REMOVE");
+----
+
+YAML::
++
+[source,yaml]
+----
+- route:
+ from:
+ uri: "direct:remove"
+ steps:
+ - setBody:
+ simple: "${header.embeddingId}"
+ - to: "langchain4j-embeddingstore:myStore?action=REMOVE"
+----
+====
+
+=== Complete RAG Pipeline Example
+
+A complete example showing document ingestion and retrieval:
+
+[source,java]
+----
+// Ingestion route: chunk, embed, and store documents
+from("file:documents?include=.*\\.txt")
+ .split().tokenize("\n\n") // Split by paragraphs
+ .to("langchain4j-embeddings:embed")
+ .to("langchain4j-embeddingstore:ragStore?action=ADD")
+ .log("Stored embedding with ID: ${body}");
+
+// Query route: embed query, search, and return text results
+from("direct:query")
+ .to("langchain4j-embeddings:embed")
+
.to("langchain4j-embeddingstore:ragStore?action=SEARCH&maxResults=3&returnTextContent=true");
+----
+
+=== Supported Vector Databases
+
+The component supports any vector database that LangChain4j provides an
`EmbeddingStore` implementation for:
+
+* **PGVector** - PostgreSQL with pgvector extension
+* **Qdrant** - High-performance vector database
+* **Milvus** - Cloud-native vector database
+* **Weaviate** - Vector search engine
+* **Chroma** - Open-source embedding database
+* **Pinecone** - Managed vector database
+* **Neo4j** - Graph database with vector capabilities
+* **InMemoryEmbeddingStore** - For testing purposes
+
+Refer to the
https://docs.langchain4j.dev/integrations/embedding-stores/[LangChain4j
Embedding Stores documentation] for the complete list and configuration options.
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfiguration.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfiguration.java
index 942b04ca45f5..632fc43f5e2c 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfiguration.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreConfiguration.java
@@ -51,6 +51,19 @@ public class LangChain4jEmbeddingStoreConfiguration
implements Cloneable {
@Metadata(autowired = true)
private EmbeddingStoreFactory embeddingStoreFactory;
+ @UriParam(description = "The operation to perform: ADD, REMOVE, or
SEARCH", enums = "ADD,REMOVE,SEARCH")
+ private LangChain4jEmbeddingStoreAction action;
+
+ @UriParam(description = "Maximum number of results to return for SEARCH
operation", defaultValue = "5")
+ private Integer maxResults = 5;
+
+ @UriParam(description = "Minimum similarity score threshold for SEARCH
operation (0.0 to 1.0)")
+ private Double minScore;
+
+ @UriParam(description = "When true, SEARCH returns List<String> with text
content instead of List<EmbeddingMatch>",
+ defaultValue = "false")
+ private boolean returnTextContent = false;
+
public EmbeddingStore<TextSegment> getEmbeddingStore() {
return embeddingStore;
}
@@ -75,6 +88,38 @@ public class LangChain4jEmbeddingStoreConfiguration
implements Cloneable {
this.embeddingStoreFactory = embeddingStoreFactory;
}
+ public LangChain4jEmbeddingStoreAction getAction() {
+ return action;
+ }
+
+ public void setAction(LangChain4jEmbeddingStoreAction action) {
+ this.action = action;
+ }
+
+ public Integer getMaxResults() {
+ return maxResults;
+ }
+
+ public void setMaxResults(Integer maxResults) {
+ this.maxResults = maxResults;
+ }
+
+ public Double getMinScore() {
+ return minScore;
+ }
+
+ public void setMinScore(Double minScore) {
+ this.minScore = minScore;
+ }
+
+ public boolean isReturnTextContent() {
+ return returnTextContent;
+ }
+
+ public void setReturnTextContent(boolean returnTextContent) {
+ this.returnTextContent = returnTextContent;
+ }
+
// ************************
//
// Clone
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreProducer.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreProducer.java
index c2727ec148c6..e0c796b84782 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreProducer.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/main/java/org/apache/camel/component/langchain4j/embeddingstore/LangChain4jEmbeddingStoreProducer.java
@@ -18,6 +18,7 @@ package org.apache.camel.component.langchain4j.embeddingstore;
import java.util.List;
import java.util.concurrent.ExecutorService;
+import java.util.stream.Collectors;
import dev.langchain4j.data.embedding.Embedding;
import dev.langchain4j.data.segment.TextSegment;
@@ -75,13 +76,18 @@ public class LangChain4jEmbeddingStoreProducer extends
DefaultProducer {
public void process(Exchange exchange) throws Exception {
final Message in = exchange.getMessage();
- final LangChain4jEmbeddingStoreAction action
+ // Get action from header, fallback to endpoint configuration
+ LangChain4jEmbeddingStoreAction action
= in.getHeader(LangChain4jEmbeddingStoreHeaders.ACTION,
LangChain4jEmbeddingStoreAction.class);
+ if (action == null) {
+ action = getEndpoint().getConfiguration().getAction();
+ }
try {
if (action == null) {
throw new NoSuchHeaderException(
- "The action is a required header", exchange,
LangChain4jEmbeddingStoreHeaders.ACTION);
+ "The action is a required header or endpoint
property", exchange,
+ LangChain4jEmbeddingStoreHeaders.ACTION);
}
switch (action) {
@@ -182,35 +188,50 @@ public class LangChain4jEmbeddingStoreProducer extends
DefaultProducer {
*/
private void search(Exchange exchange) throws Exception {
final Message in = exchange.getMessage();
- Embedding embedding = null;
- if (in.getHeader(LangChain4jEmbeddingsHeaders.EMBEDDING) != null) {
- embedding = in.getHeader(LangChain4jEmbeddingsHeaders.EMBEDDING,
Embedding.class);
- }
+ LangChain4jEmbeddingStoreConfiguration config =
getEndpoint().getConfiguration();
+
+ Embedding embedding =
in.getHeader(LangChain4jEmbeddingsHeaders.EMBEDDING, Embedding.class);
- int maxResults =
Integer.parseInt(LangChain4jEmbeddingStore.DEFAULT_MAX_RESULTS);
- if (in.getHeader(LangChain4jEmbeddingStoreHeaders.MAX_RESULTS,
Integer.class) != null) {
- maxResults =
in.getHeader(LangChain4jEmbeddingStoreHeaders.MAX_RESULTS, Integer.class);
+ // Get maxResults from header, fallback to endpoint config
+ Integer maxResults =
in.getHeader(LangChain4jEmbeddingStoreHeaders.MAX_RESULTS, Integer.class);
+ if (maxResults == null) {
+ maxResults = config.getMaxResults();
}
EmbeddingSearchRequestBuilder esrb = EmbeddingSearchRequest.builder()
.queryEmbedding(embedding)
.maxResults(maxResults);
- if (in.getHeader(LangChain4jEmbeddingStoreHeaders.MIN_SCORE,
Integer.class) != null) {
- Double minScore =
in.getHeader(LangChain4jEmbeddingStoreHeaders.MIN_SCORE, Double.class);
+ // Get minScore from header, fallback to endpoint config
+ Double minScore =
in.getHeader(LangChain4jEmbeddingStoreHeaders.MIN_SCORE, Double.class);
+ if (minScore == null) {
+ minScore = config.getMinScore();
+ }
+ if (minScore != null) {
esrb = esrb.minScore(minScore);
}
- if (in.getHeader(LangChain4jEmbeddingStoreHeaders.FILTER,
Filter.class) != null) {
- Filter filter =
in.getHeader(LangChain4jEmbeddingStoreHeaders.FILTER, Filter.class);
+ Filter filter = in.getHeader(LangChain4jEmbeddingStoreHeaders.FILTER,
Filter.class);
+ if (filter != null) {
esrb = esrb.filter(filter);
}
+
EmbeddingSearchRequest embeddingSearchRequest = esrb.build();
+ List<EmbeddingMatch<TextSegment>> matches
+ =
config.getEmbeddingStore().search(embeddingSearchRequest).matches();
- List<EmbeddingMatch<TextSegment>> result
- =
getEndpoint().getConfiguration().getEmbeddingStore().search(embeddingSearchRequest).matches();
Message out = exchange.getMessage();
- out.setBody(result);
+
+ // Return text content if configured
+ if (config.isReturnTextContent()) {
+ List<String> texts = matches.stream()
+ .filter(m -> m.embedded() != null)
+ .map(m -> m.embedded().text())
+ .collect(Collectors.toList());
+ out.setBody(texts);
+ } else {
+ out.setBody(matches);
+ }
}
private CamelContext getCamelContext() {
diff --git
a/components/camel-ai/camel-langchain4j-embeddingstore/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingStoreComponentQdrantTargetIT.java
b/components/camel-ai/camel-langchain4j-embeddingstore/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingStoreComponentQdrantTargetIT.java
index cf0f6a5c79c7..058347e7aa66 100644
---
a/components/camel-ai/camel-langchain4j-embeddingstore/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingStoreComponentQdrantTargetIT.java
+++
b/components/camel-ai/camel-langchain4j-embeddingstore/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingStoreComponentQdrantTargetIT.java
@@ -142,6 +142,49 @@ public class
LangChain4jEmbeddingStoreComponentQdrantTargetIT extends CamelTestS
@Test
@Order(3)
+ public void searchWithEndpointProperties() {
+ EmbeddingModel embeddingModel = new AllMiniLmL6V2EmbeddingModel();
+
+ TextSegment segment1 = TextSegment.from("I like football.");
+ Embedding embedding = embeddingModel.embed(segment1).content();
+
+ // Test using action as endpoint property (no header needed)
+ Exchange result =
fluentTemplate.to("direct:searchWithEndpointProperties")
+ .withHeader(LangChain4jEmbeddingsHeaders.EMBEDDING, embedding)
+ .request(Exchange.class);
+
+ assertThat(result).isNotNull();
+ assertThat(result.getException()).isNull();
+
+ List<EmbeddingMatch<TextSegment>> embeddingMatches = (List)
result.getIn().getBody();
+ assertThat(embeddingMatches).isNotNull();
+ assertTrue(embeddingMatches.size() > 0);
+ }
+
+ @Test
+ @Order(4)
+ public void searchWithReturnTextContent() {
+ EmbeddingModel embeddingModel = new AllMiniLmL6V2EmbeddingModel();
+
+ TextSegment segment1 = TextSegment.from("I like football.");
+ Embedding embedding = embeddingModel.embed(segment1).content();
+
+ // Test using returnTextContent option
+ Exchange result =
fluentTemplate.to("direct:searchWithReturnTextContent")
+ .withHeader(LangChain4jEmbeddingsHeaders.EMBEDDING, embedding)
+ .request(Exchange.class);
+
+ assertThat(result).isNotNull();
+ assertThat(result.getException()).isNull();
+
+ List<String> textResults = (List<String>) result.getIn().getBody();
+ assertThat(textResults).isNotNull();
+ assertTrue(textResults.size() > 0);
+ assertThat(textResults.get(0)).isEqualTo("I like football.");
+ }
+
+ @Test
+ @Order(5)
public void remove() {
Exchange result = fluentTemplate.to("direct:remove")
.withHeader(LangChain4jEmbeddingStoreHeaders.ACTION,
LangChain4jEmbeddingStoreAction.REMOVE)
@@ -170,6 +213,14 @@ public class
LangChain4jEmbeddingStoreComponentQdrantTargetIT extends CamelTestS
.to("langchain4j-embeddingstore:test")
.setHeader(LangChain4jEmbeddingStoreHeaders.ACTION,
constant(LangChain4jEmbeddingStoreAction.REMOVE))
.to(QDRANT_URI);
+
+ // Route using action as endpoint property
+ from("direct:searchWithEndpointProperties")
+ .to(QDRANT_URI + "?action=SEARCH&maxResults=3");
+
+ // Route using returnTextContent option
+ from("direct:searchWithReturnTextContent")
+ .to(QDRANT_URI +
"?action=SEARCH&maxResults=5&returnTextContent=true");
}
};
}
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Langchain4jEmbeddingstoreComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Langchain4jEmbeddingstoreComponentBuilderFactory.java
index 42765fab0ecf..80d259017c86 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Langchain4jEmbeddingstoreComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Langchain4jEmbeddingstoreComponentBuilderFactory.java
@@ -50,6 +50,22 @@ public interface
Langchain4jEmbeddingstoreComponentBuilderFactory {
*/
interface Langchain4jEmbeddingstoreComponentBuilder extends
ComponentBuilder<LangChain4jEmbeddingStoreComponent> {
+ /**
+ * The operation to perform: ADD, REMOVE, or SEARCH.
+ *
+ * The option is a:
+ *
<code>org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction</code>
type.
+ *
+ * Group: producer
+ *
+ * @param action the value to set
+ * @return the dsl builder
+ */
+ default Langchain4jEmbeddingstoreComponentBuilder
action(org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction
action) {
+ doSetProperty("action", action);
+ return this;
+ }
+
/**
* The configuration;.
*
@@ -125,6 +141,55 @@ public interface
Langchain4jEmbeddingstoreComponentBuilderFactory {
}
+ /**
+ * Maximum number of results to return for SEARCH operation.
+ *
+ * The option is a: <code>java.lang.Integer</code> type.
+ *
+ * Default: 5
+ * Group: producer
+ *
+ * @param maxResults the value to set
+ * @return the dsl builder
+ */
+ default Langchain4jEmbeddingstoreComponentBuilder
maxResults(java.lang.Integer maxResults) {
+ doSetProperty("maxResults", maxResults);
+ return this;
+ }
+
+ /**
+ * Minimum similarity score threshold for SEARCH operation (0.0 to
1.0).
+ *
+ * The option is a: <code>java.lang.Double</code> type.
+ *
+ * Group: producer
+ *
+ * @param minScore the value to set
+ * @return the dsl builder
+ */
+ default Langchain4jEmbeddingstoreComponentBuilder
minScore(java.lang.Double minScore) {
+ doSetProperty("minScore", minScore);
+ return this;
+ }
+
+
+ /**
+ * When true, SEARCH returns List with text content instead of List.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param returnTextContent the value to set
+ * @return the dsl builder
+ */
+ default Langchain4jEmbeddingstoreComponentBuilder
returnTextContent(boolean returnTextContent) {
+ doSetProperty("returnTextContent", returnTextContent);
+ return this;
+ }
+
+
/**
* Whether autowiring is enabled. This is used for automatic autowiring
* options (the option must be marked as autowired) by looking up in
the
@@ -166,10 +231,14 @@ public interface
Langchain4jEmbeddingstoreComponentBuilderFactory {
String name,
Object value) {
switch (name) {
+ case "action":
getOrCreateConfiguration((LangChain4jEmbeddingStoreComponent)
component).setAction((org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction)
value); return true;
case "configuration": ((LangChain4jEmbeddingStoreComponent)
component).setConfiguration((org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreConfiguration)
value); return true;
case "embeddingStore":
getOrCreateConfiguration((LangChain4jEmbeddingStoreComponent)
component).setEmbeddingStore((dev.langchain4j.store.embedding.EmbeddingStore)
value); return true;
case "embeddingStoreFactory":
getOrCreateConfiguration((LangChain4jEmbeddingStoreComponent)
component).setEmbeddingStoreFactory((org.apache.camel.component.langchain4j.embeddingstore.EmbeddingStoreFactory)
value); return true;
case "lazyStartProducer": ((LangChain4jEmbeddingStoreComponent)
component).setLazyStartProducer((boolean) value); return true;
+ case "maxResults":
getOrCreateConfiguration((LangChain4jEmbeddingStoreComponent)
component).setMaxResults((java.lang.Integer) value); return true;
+ case "minScore":
getOrCreateConfiguration((LangChain4jEmbeddingStoreComponent)
component).setMinScore((java.lang.Double) value); return true;
+ case "returnTextContent":
getOrCreateConfiguration((LangChain4jEmbeddingStoreComponent)
component).setReturnTextContent((boolean) value); return true;
case "autowiredEnabled": ((LangChain4jEmbeddingStoreComponent)
component).setAutowiredEnabled((boolean) value); return true;
default: return false;
}
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LangChain4jEmbeddingStoreEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LangChain4jEmbeddingStoreEndpointBuilderFactory.java
index d6acdff28952..5f1cf524a1a5 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LangChain4jEmbeddingStoreEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LangChain4jEmbeddingStoreEndpointBuilderFactory.java
@@ -44,6 +44,36 @@ public interface
LangChain4jEmbeddingStoreEndpointBuilderFactory {
return (AdvancedLangChain4jEmbeddingStoreEndpointBuilder) this;
}
+ /**
+ * The operation to perform: ADD, REMOVE, or SEARCH.
+ *
+ * The option is a:
+ *
<code>org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction</code>
type.
+ *
+ * Group: producer
+ *
+ * @param action the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder
action(org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction
action) {
+ doSetProperty("action", action);
+ return this;
+ }
+ /**
+ * The operation to perform: ADD, REMOVE, or SEARCH.
+ *
+ * The option will be converted to a
+ *
<code>org.apache.camel.component.langchain4j.embeddingstore.LangChain4jEmbeddingStoreAction</code>
type.
+ *
+ * Group: producer
+ *
+ * @param action the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder action(String action)
{
+ doSetProperty("action", action);
+ return this;
+ }
/**
* Direct embedding store instance for vector operations.
*
@@ -106,6 +136,95 @@ public interface
LangChain4jEmbeddingStoreEndpointBuilderFactory {
doSetProperty("embeddingStoreFactory", embeddingStoreFactory);
return this;
}
+ /**
+ * Maximum number of results to return for SEARCH operation.
+ *
+ * The option is a: <code>java.lang.Integer</code> type.
+ *
+ * Default: 5
+ * Group: producer
+ *
+ * @param maxResults the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder maxResults(Integer
maxResults) {
+ doSetProperty("maxResults", maxResults);
+ return this;
+ }
+ /**
+ * Maximum number of results to return for SEARCH operation.
+ *
+ * The option will be converted to a <code>java.lang.Integer</code>
+ * type.
+ *
+ * Default: 5
+ * Group: producer
+ *
+ * @param maxResults the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder maxResults(String
maxResults) {
+ doSetProperty("maxResults", maxResults);
+ return this;
+ }
+ /**
+ * Minimum similarity score threshold for SEARCH operation (0.0 to
1.0).
+ *
+ * The option is a: <code>java.lang.Double</code> type.
+ *
+ * Group: producer
+ *
+ * @param minScore the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder minScore(Double
minScore) {
+ doSetProperty("minScore", minScore);
+ return this;
+ }
+ /**
+ * Minimum similarity score threshold for SEARCH operation (0.0 to
1.0).
+ *
+ * The option will be converted to a <code>java.lang.Double</code>
type.
+ *
+ * Group: producer
+ *
+ * @param minScore the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder minScore(String
minScore) {
+ doSetProperty("minScore", minScore);
+ return this;
+ }
+ /**
+ * When true, SEARCH returns List with text content instead of List.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param returnTextContent the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder
returnTextContent(boolean returnTextContent) {
+ doSetProperty("returnTextContent", returnTextContent);
+ return this;
+ }
+ /**
+ * When true, SEARCH returns List with text content instead of List.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param returnTextContent the value to set
+ * @return the dsl builder
+ */
+ default LangChain4jEmbeddingStoreEndpointBuilder
returnTextContent(String returnTextContent) {
+ doSetProperty("returnTextContent", returnTextContent);
+ return this;
+ }
}
/**
