This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/maven/google-cloud-99b5a5e48d
in repository https://gitbox.apache.org/repos/asf/camel.git
omit 6b076ef413f9 chore(deps): Bump the google-cloud group across 1
directory with 10 updates
add 77a330bb8c83 CAMEL-26174: camel-stitch - accept key_names as a String
and any Number as sequence in a Map body, and set the response headers for an
empty response body (#28999)
add 1007d56a7fde CAMEL-26170: camel-geocoder - Nominatim sets ZERO_RESULTS
when it finds no place (#29000)
add 0c158cbdb6f7 CAMEL-26461: camel-core - NoErrorHandler: an
AsyncProcessor that throws fails the exchange instead of hanging (#29041)
add 394deda18cf8 CAMEL-26433: camel-hl7 - add a maxFrameLength option to
the HL7 MLLP MINA codec (#29043)
add 7d361fc3d308 CAMEL-26173: camel-web3j - atBlock, fromBlock and toBlock
default to latest, ETH_GET_TRANSACTION_RECEIPT gives the receipt, and a missing
operation fails with a clear message (#29002)
add e46a3119b912 CAMEL-26176: camel-olingo4 - filterAlreadySeen keeps the
type of a complex or collection value (#29005)
add 0f11a4a21c33 CAMEL-26177: camel-dhis2 - post/put send bytes, a stream
or a file as the JSON it holds, delete does not send a leftover body, and the
get/collection consumer sends one message per item (#29006)
add a84ea1391ed0 CAMEL-26183: camel-mllp - the producer converts a body
that is not a String or a byte array (#29008)
add e6ae7a3dad08 CAMEL-26185: camel-asterisk - QUEUE_STATUS and SIP_PEERS
return the events of the list (#29009)
add 2d8b6e0da222 CAMEL-26182: camel-mina - sync=false is one-way: the
producer keeps the message and the consumer writes no reply, and a textline
consumer converts the reply to a String (#29010)
add 6a7e17a1af69 CAMEL-26187: camel-grpc - the consumer converts the reply
to the response type of the method, or fails the call (#29012)
add 038fd8268a44 CAMEL-26195: camel-opentelemetry-metrics - a counter
increment or decrement that does not give a number fails the exchange (#29019)
add 7ee0d02c48d4 CAMEL-26194: camel-zookeeper - the producer waits for
every write, fails on a body it cannot store, and a DELETE never creates a
znode (#29020)
add 5bc24e361bf3 CAMEL-26191: camel-docker - the streaming operations give
their result and fail the exchange on errors, and the events since time is in
seconds (#29021)
add 8f7cfa4b5423 CAMEL-26199: camel-spring-ldap - a body that is not a
Map, or no body, fails with an InvalidPayloadException naming the Map (#29022)
add b875a54603d4 CAMEL-26202: camel-langchain4j-agent - send a file, bytes
or stream content once without a user message, accept JSON/XML/YAML and
File/Path bodies (#29026)
add 37d00fa53bce CAMEL-26200: camel-ldif - bind the connection for every
message, give the result code and DN of a failed change, and an empty body for
an empty body (#29027)
add a8cd7c27ff07 CAMEL-26203: camel-langchain4j-web-search - do not
autowire webSearchRequest and additionalParams, and give the snippet of a
result without content (#29028)
add c4da338913a9 CAMEL-26208: camel-spring-ai-embeddings - a List body
always gives a List of vectors, and its elements are converted to text (#29031)
add 787da26fa220 CAMEL-26205: camel-langchain4j-embeddings - embed bytes,
stream and file bodies as text, and remove the headers of an earlier call
(#29032)
add 82993a5e83f0 CAMEL-26207: camel-spring-ai-chat - keep the question
with outputFormat, send File, Path and stream bodies as media, and fail media
without a user message clearly (#29035)
add 4385357bc2b0 CAMEL-26234: camel-elasticsearch-rest-client - SEARCH
sends a JSON body as the query, GET_BY_ID and DELETE prefer the
CamelElasticsearchId header to the body, and the doc names the real headers
(#29076)
add d5245ccd0ec9 CAMEL-26226: camel-cassandraql - remove the copy of the
in message onto itself in CassandraProducer (#29069)
add 9cab3498630a CAMEL-26272: camel-duckdb - honour the
CamelDuckDbDatabasePath header only with allowDatabasePathFromHeader=true, and
document the headers that override the endpoint (#29081)
add ee986cad332a CAMEL-26238: camel-jcache - PUTALL fails with an
InvalidPayloadException when the body is not a Map (#29079)
add 17ba42af2df0 CAMEL-26236: camel-ignite - the existing query results
carry the key header, a PUT of a Map with a key stores it as one value, RUN
keeps the body, and no operation or no body fails with a clear message (#29078)
add 3e995e4b664d CAMEL-26235: camel-hazelcast - clear errors for a missing
operation, header or body, getAll copies, map expired events and a working
queue removeIf (#29077)
add 28f5ef2ba89e CAMEL-26233: camel-opensearch - send a built request as
it is, keep the whole JSON search body, take the DeleteIndex name from a String
body, fail a null Index/Update body and read a file as JSON (#29075)
add b539152f3524 CAMEL-26231: camel-influxdb - fail the exchange on a
query error, do not change the Map body, and accept the operation in any case
and check it at startup (#29073)
add 53219dce7deb CAMEL-26230: camel-influxdb2 - fail a Point without
fields, call InfluxDB at startup only to create the organization or bucket, and
do not change the Map body (#29072)
add 400e24d23203 CAMEL-26228: camel-neo4j - fail clearly on CREATE_NODE
without a body and on a search body that is not a vector, search with a List or
array of numbers, give Cypher records whose first column is not a node and the
score of each hit, and fix the header metadata (#29070)
add 177686ba2acc CAMEL-26225: camel-arangodb - SAVE_DOCUMENT inserts a
Collection body as several documents, and a producer without the operation
option fails to start (#29068)
add bf3d66b57593 CAMEL-26218: camel-kserve - a body that is not the
request of infer, model/ready or model/metadata fails instead of being dropped
(#29065)
add de36cecfda63 CAMEL-26217: camel-tensorflow-serving - a body that is
not the request of the api fails instead of being dropped, and model-metadata
asks for signature_def once (#29064)
add d20702f9101e CAMEL-26215: camel-pgvector - take the vector as a List
of any numbers, such as the List of Double a JSON array gives, or a float or
double array (#29062)
add db2e22647dc3 CAMEL-26214: camel-weaviate - take the vector as a List
of any numbers, such as the List of Double a JSON array gives, or a float or
double array (#29061)
add 8b71b79af6dd CAMEL-26213: camel-chatscript - send the first message
after starting the conversation, keep the headers, and reset the user of the
message (#29060)
add a8b99c70c4fe CAMEL-25919: camel-core - setOutput with a directory
clears the file name of a previous setOutput (#29050)
add d3d5ada10364 CAMEL-26533: camel-jpa - bind CamelJpaParameters header
values literally (#29084)
add 5b6ee1efaaad CAMEL-24781: Support Kafka exactly-once processing
(#28730)
add 2b71d300dd70 CAMEL-26508, CAMEL-26322: docs - add the netty
transferExchange and as2 MDN allow-list upgrade notes to the 4.22.3 and 4.18.6
sections of the upgrade guides on main (#29086)
add 8bd7c2ed53b7 CAMEL-26487: camel-netty-http - include the endpoint
options in the endpoint URI (#28863)
add 7bf4337815dc CAMEL-26171: camel-xchange - convert currency and
currency pair text, and fail an endpoint with a method of another service
(#29001)
add aae6e407db76 CAMEL-26210: camel-spring-ai-vector-store - DELETE takes
the ids from the body first, and the embeddings headers only go with a vector
body (#29036)
add e4fb56f5f75b CAMEL-26273: camel-clickhouse - honour the database and
table headers only with allowDatabaseAndTableFromHeaders=true, and document the
headers that override the endpoint (#29082)
add 012d7fd13a3d chore(deps): Upgrade mariadb-java-client to 4.0.0 (#28990)
add 8b420c9dee9f CAMEL-26487: docs - upgrade notes for camel-netty-http
endpoint equality in 4.22.3 and 4.18.6 (#29097)
add f09048618797 CAMEL-26530: camel-observability-services - promote to
stable support level
add 8d65b21af325 Regen
add 0aedc4dfb810 CAMEL-25488: camel-jgroups-raft - tests use their own log
and wait for the election to end before closing the channels
add bb3a1bb45927 camel-cxf - stabilize flaky BindException in SSL
jaxrs/jaxws tests
add fd9a47efde74 CAMEL-26509: camel-core - TypeConversionException gives
the real from type, and ArrayTypeConverter gives no conversion for an element
that does not fit (#29111)
add 5b7f3963e414 CAMEL-26255: camel-hashicorp-vault - cloud without a
namespace uses the engine, createSecret takes JSON text and needs a body, and
the secret version must be a number (#29100)
add 7a69b7469305 CAMEL-26239: camel-state-store - put and putIfAbsent
store a stream body as its bytes (#29080)
add fb25ea44ee9d CAMEL-26232: camel-elasticsearch - send a built request
as it is, keep the whole JSON search body, take the DeleteIndex name from a
String body, fail a null Index/Update body and read a file as JSON (#29074)
add b0d94141a1ae CAMEL-26229: camel-mongodb-gridfs - the consumer offers
the file of a failed exchange again, closes the download stream and sets
CamelFileName, an unknown producer operation fails, and listAll gives the hex
id (#29071)
add 703d4fcbdae4 CAMEL-26219: camel-huggingface - bound the chat
histories, fail only on the error payload of the Python handler, and set no
Content-Type for text-to-speech (#29066)
add 2a821fd47497 CAMEL-26454: camel-jbang-mcp - chaos tools:
camel_runtime_chaos_* and the chaos tool group (#29047)
add a151475a461b CAMEL-26106: camel-jpa: don't hard-wire the Spring based
DefaultTransactionStrategy as the default (#28496)
add 9950f2b0e725 CAMEL-26245: camel-api-component-maven-plugin - use the
substituted argument names in the method signatures (#29099)
add 446cc76aa55b CAMEL-26277: camel-xmpp - a consumer with a participant
routes only the chat messages from that participant (#29106)
add c4ba416b02f1 CAMEL-26137: camel-netty-http - reply to a List body and
to the request body sent back with disableStreamCache, keep the message with
sync=false (#29103)
add c885344db813 CAMEL-26511: camel-docker - document socket=false as the
default, and use /var/run/docker.sock in socket mode with the default host
(#29107)
add 09a755e18cf9 chore: correct camel-mina disconnectOnNoReply docs
(option has no effect since 4.24.0) (#28947)
add 6469c548d6f7 CAMEL-25823: camel-core - Start Split and Multicast
output producers when the route starts (#28147)
add 41a9b22a6788 CAMEL-26419: camel-azure-cosmosdb - a readiness health
check for a consumer whose change feed processor has not started yet (#29045)
add 417cad3d49db chore(deps): Bump the google-cloud group across 1
directory with 10 updates
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6b076ef413f9)
\
N -- N -- N refs/heads/dependabot/maven/google-cloud-99b5a5e48d
(417cad3d49db)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../apache/camel/catalog/components/arangodb.json | 4 +-
.../apache/camel/catalog/components/asterisk.json | 2 +-
.../apache/camel/catalog/components/braintree.json | 8 +-
.../camel/catalog/components/clickhouse.json | 13 +-
.../org/apache/camel/catalog/components/dhis2.json | 4 +-
.../apache/camel/catalog/components/docker.json | 16 +-
.../apache/camel/catalog/components/duckdb.json | 5 +-
.../components/elasticsearch-rest-client.json | 2 +-
.../camel/catalog/components/elasticsearch.json | 2 +-
.../apache/camel/catalog/components/geocoder.json | 2 +-
.../camel/catalog/components/google-calendar.json | 10 +-
.../camel/catalog/components/google-drive.json | 6 +-
.../camel/catalog/components/google-mail.json | 2 +-
.../camel/catalog/components/google-sheets.json | 4 +-
.../org/apache/camel/catalog/components/grpc.json | 2 +-
.../camel/catalog/components/hashicorp-vault.json | 2 +-
.../camel/catalog/components/hazelcast-list.json | 2 +-
.../camel/catalog/components/hazelcast-map.json | 2 +-
.../catalog/components/hazelcast-pncounter.json | 3 +
.../camel/catalog/components/hazelcast-queue.json | 4 +-
.../camel/catalog/components/hazelcast-set.json | 2 +-
.../camel/catalog/components/huggingface.json | 76 +-
.../camel/catalog/components/ignite-cache.json | 6 +-
.../camel/catalog/components/ignite-compute.json | 4 +-
.../camel/catalog/components/ignite-idgen.json | 2 +-
.../camel/catalog/components/ignite-queue.json | 2 +-
.../apache/camel/catalog/components/influxdb.json | 4 +-
.../apache/camel/catalog/components/influxdb2.json | 2 +-
.../org/apache/camel/catalog/components/jpa.json | 4 +-
.../org/apache/camel/catalog/components/kafka.json | 482 +++++------
.../apache/camel/catalog/components/kserve.json | 2 +-
.../catalog/components/langchain4j-agent.json | 2 +-
.../catalog/components/langchain4j-embeddings.json | 4 +-
.../catalog/components/langchain4j-web-search.json | 8 +-
.../org/apache/camel/catalog/components/ldif.json | 4 +-
.../org/apache/camel/catalog/components/mina.json | 8 +-
.../org/apache/camel/catalog/components/mllp.json | 2 +-
.../camel/catalog/components/mongodb-gridfs.json | 8 +-
.../org/apache/camel/catalog/components/neo4j.json | 26 +-
.../camel/catalog/components/netty-http.json | 2 +-
.../apache/camel/catalog/components/olingo4.json | 4 +-
.../camel/catalog/components/opensearch.json | 2 +-
.../catalog/components/opentelemetry-metrics.json | 4 +-
.../apache/camel/catalog/components/pgvector.json | 2 +-
.../camel/catalog/components/spring-ai-chat.json | 2 +-
.../catalog/components/spring-ai-embeddings.json | 4 +-
.../catalog/components/spring-ai-vector-store.json | 6 +-
.../camel/catalog/components/state-store.json | 4 +-
.../apache/camel/catalog/components/stitch.json | 2 +-
.../catalog/components/tensorflow-serving.json | 2 +-
.../apache/camel/catalog/components/weaviate.json | 2 +-
.../org/apache/camel/catalog/components/web3j.json | 6 +-
.../apache/camel/catalog/components/xchange.json | 4 +-
.../org/apache/camel/catalog/components/xmpp.json | 2 +-
.../apache/camel/catalog/components/zendesk.json | 2 +-
.../apache/camel/catalog/components/zookeeper.json | 8 +-
.../camel/catalog/docs/arangodb-component.adoc | 6 +
.../camel/catalog/docs/asterisk-component.adoc | 9 +
.../catalog/docs/azure-cosmosdb-component.adoc | 13 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 16 +-
.../camel/catalog/docs/chatscript-component.adoc | 8 +-
.../camel/catalog/docs/clickhouse-component.adoc | 14 +
.../apache/camel/catalog/docs/dhis2-component.adoc | 10 +
.../camel/catalog/docs/docker-component.adoc | 38 +
.../camel/catalog/docs/duckdb-component.adoc | 21 +-
.../catalog/docs/elasticsearch-component.adoc | 31 +-
.../docs/elasticsearch-rest-client-component.adoc | 31 +-
.../camel/catalog/docs/geocoder-component.adoc | 2 +
.../apache/camel/catalog/docs/grpc-component.adoc | 10 +
.../catalog/docs/hashicorp-vault-component.adoc | 9 +-
.../catalog/docs/hazelcast-list-component.adoc | 3 +-
.../catalog/docs/hazelcast-map-component.adoc | 30 +-
.../catalog/docs/hazelcast-multimap-component.adoc | 32 +-
.../docs/hazelcast-pncounter-component.adoc | 42 +-
.../catalog/docs/hazelcast-queue-component.adoc | 7 +
.../docs/hazelcast-replicatedmap-component.adoc | 26 +-
.../docs/hazelcast-ringbuffer-component.adoc | 8 +-
.../catalog/docs/hazelcast-set-component.adoc | 2 +-
.../apache/camel/catalog/docs/hl7-dataformat.adoc | 31 +-
.../camel/catalog/docs/huggingface-component.adoc | 28 +-
.../camel/catalog/docs/ignite-cache-component.adoc | 6 +-
.../catalog/docs/ignite-compute-component.adoc | 3 +
.../camel/catalog/docs/ignite-idgen-component.adoc | 4 +
.../camel/catalog/docs/ignite-queue-component.adoc | 3 +
.../camel/catalog/docs/ignite-set-component.adoc | 3 +
.../camel/catalog/docs/influxdb-component.adoc | 12 +
.../camel/catalog/docs/influxdb2-component.adoc | 17 +
.../camel/catalog/docs/jcache-component.adoc | 2 +
.../apache/camel/catalog/docs/jpa-component.adoc | 26 +-
.../apache/camel/catalog/docs/kafka-component.adoc | 159 +++-
.../camel/catalog/docs/kserve-component.adoc | 7 +
.../catalog/docs/langchain4j-agent-multimodal.adoc | 15 +
.../docs/langchain4j-embeddings-component.adoc | 15 +
.../docs/langchain4j-web-search-component.adoc | 18 +-
.../apache/camel/catalog/docs/ldif-component.adoc | 26 +-
.../apache/camel/catalog/docs/mina-component.adoc | 18 +-
.../apache/camel/catalog/docs/mllp-component.adoc | 5 +-
.../catalog/docs/mongodb-gridfs-component.adoc | 34 +-
.../apache/camel/catalog/docs/neo4j-component.adoc | 20 +-
.../apache/camel/catalog/docs/netty-component.adoc | 2 +-
.../camel/catalog/docs/observability-services.adoc | 2 +-
.../camel/catalog/docs/opensearch-component.adoc | 31 +-
.../docs/opentelemetry-metrics-component.adoc | 2 +
.../camel/catalog/docs/pgvector-component.adoc | 4 +-
.../catalog/docs/spring-ai-chat-component.adoc | 12 +
.../docs/spring-ai-embeddings-component.adoc | 6 +-
.../docs/spring-ai-vector-store-component.adoc | 31 +-
.../camel/catalog/docs/spring-ldap-component.adoc | 3 +-
.../camel/catalog/docs/state-store-component.adoc | 9 +
.../camel/catalog/docs/stitch-component.adoc | 3 +-
.../catalog/docs/tensorflow-serving-component.adoc | 9 +
.../camel/catalog/docs/weaviate-component.adoc | 2 +-
.../camel/catalog/docs/xchange-component.adoc | 22 +
.../apache/camel/catalog/docs/xmpp-component.adoc | 6 +
.../camel/catalog/docs/zookeeper-component.adoc | 15 +-
.../catalog/others/observability-services.json | 2 +-
.../src/main/docs/chatscript-component.adoc | 8 +-
.../camel/component/chatscript/ChatScriptBot.java | 36 +-
.../component/chatscript/ChatScriptMessage.java | 7 +-
.../component/chatscript/ChatScriptProducer.java | 11 +-
.../chatscript/ChatScriptConversationTest.java | 171 ++++
.../component/chatscript/FakeChatScriptServer.java | 99 +++
.../HuggingFaceComponentConfigurer.java | 12 +
.../huggingface/HuggingFaceEndpointConfigurer.java | 12 +
.../huggingface/HuggingFaceEndpointUriFactory.java | 4 +-
.../camel/component/huggingface/huggingface.json | 76 +-
.../src/main/docs/huggingface-component.adoc | 28 +-
.../huggingface/HuggingFaceConfiguration.java | 29 +
.../huggingface/tasks/AbstractTaskPredictor.java | 41 +
.../tasks/AutomaticSpeechRecognitionPredictor.java | 6 +-
.../component/huggingface/tasks/ChatPredictor.java | 50 +-
.../tasks/QuestionAnsweringPredictor.java | 5 +-
.../tasks/SentenceEmbeddingsPredictor.java | 5 +-
.../huggingface/tasks/SummarizationPredictor.java | 5 +-
.../tasks/TextClassificationPredictor.java | 7 +-
.../huggingface/tasks/TextGenerationPredictor.java | 5 +-
.../huggingface/tasks/TextToImagePredictor.java | 9 +-
.../huggingface/tasks/TextToSpeechPredictor.java | 13 +-
.../tasks/ZeroShotClassificationPredictor.java | 5 +-
.../huggingface/tasks/ChatHistoryTest.java | 197 +++++
.../tasks/PredictorErrorHandlingTest.java | 167 +++-
.../tasks/RevisionAndOutputHeaderTest.java | 26 +
.../org/apache/camel/component/kserve/kserve.json | 2 +-
.../src/main/docs/kserve-component.adoc | 7 +
.../camel/component/kserve/KServeEndpoint.java | 20 +-
.../camel/component/kserve/KServeProducer.java | 50 +-
.../component/kserve/KServeProducerBodyTest.java | 268 ++++++
.../langchain4j/agent/api/AgentWithMemory.java | 8 +-
.../langchain4j/agent/api/AgentWithoutMemory.java | 8 +-
.../agent/api/AiAgentWithMemoryService.java | 21 +
.../agent/api/AiAgentWithoutMemoryService.java | 18 +
.../agent/LangChain4jAgentConverterLoader.java | 16 +
.../langchain4j/agent/langchain4j-agent.json | 2 +-
.../main/docs/langchain4j-agent-multimodal.adoc | 15 +
.../agent/LangChain4jAgentConverter.java | 110 ++-
.../agent/LangChain4jAgentEndpoint.java | 11 +-
.../agent/LangChain4jAgentContentBodyTest.java | 286 +++++++
.../embeddings/langchain4j-embeddings.json | 4 +-
.../docs/langchain4j-embeddings-component.adoc | 15 +
.../embeddings/LangChain4jEmbeddings.java | 2 +-
.../embeddings/LangChain4jEmbeddingsEndpoint.java | 9 +-
.../embeddings/LangChain4jEmbeddingsHeaders.java | 2 +-
.../embeddings/LangChain4jEmbeddingsProducer.java | 80 +-
.../embeddings/LangChain4jEmbeddingsBodyTest.java | 228 +++++
.../LangChain4jWebSearchEndpointConfigurer.java | 2 +-
.../web/search/langchain4j-web-search.json | 8 +-
.../docs/langchain4j-web-search-component.adoc | 18 +-
.../search/LangChain4jWebSearchConfiguration.java | 10 +-
.../web/search/LangChain4jWebSearchEndpoint.java | 6 +-
.../web/search/LangChain4jWebSearchProducer.java | 13 +-
.../LangChain4jWebSearchAdditionalParamsTest.java | 87 ++
.../search/LangChain4jWebSearchAutowireTest.java | 90 ++
.../search/LangChain4jWebSearchContentTest.java | 77 ++
.../mcp/server/jbang/JbangDevMcpServer.java | 13 +-
.../org/apache/camel/component/neo4j/neo4j.json | 26 +-
.../camel-neo4j/src/main/docs/neo4j-component.adoc | 20 +-
.../camel/component/neo4j/Neo4jConfiguration.java | 14 +
.../camel/component/neo4j/Neo4jEndpoint.java | 13 +-
.../apache/camel/component/neo4j/Neo4jHeaders.java | 32 +-
.../camel/component/neo4j/Neo4jProducer.java | 119 ++-
.../component/neo4j/Neo4jProducerBodyTest.java | 343 ++++++++
.../camel/component/neo4j/it/Neo4jNodeIT.java | 26 +
.../neo4j/it/Neo4jVectorEmbeddingsIT.java | 16 +
.../apache/camel/component/pgvector/pgvector.json | 2 +-
.../src/main/docs/pgvector-component.adoc | 4 +-
.../camel/component/pgvector/PgVectorEndpoint.java | 11 +-
.../camel/component/pgvector/PgVectorProducer.java | 45 +-
.../component/pgvector/PgVectorVectorBodyTest.java | 159 ++++
.../tensorflow/serving/tensorflow-serving.json | 2 +-
.../main/docs/tensorflow-serving-component.adoc | 9 +
.../serving/TensorFlowServingEndpoint.java | 25 +-
.../serving/TensorFlowServingProducer.java | 71 +-
.../serving/TensorFlowServingProducerBodyTest.java | 326 +++++++
.../apache/camel/component/weaviate/weaviate.json | 2 +-
.../src/main/docs/weaviate-component.adoc | 2 +-
.../weaviate/WeaviateVectorDbEndpoint.java | 14 +-
.../weaviate/WeaviateVectorDbProducer.java | 56 +-
.../component/weaviate/WeaviateVectorBodyTest.java | 212 +++++
.../apache/camel/component/arangodb/arangodb.json | 4 +-
.../src/main/docs/arangodb-component.adoc | 6 +
.../camel/component/arangodb/ArangoDbEndpoint.java | 18 +-
.../camel/component/arangodb/ArangoDbProducer.java | 6 +-
.../component/arangodb/ArangoDbProducerTest.java | 195 +++++
.../apache/camel/component/asterisk/asterisk.json | 2 +-
.../src/main/docs/asterisk-component.adoc | 9 +
.../component/asterisk/AsteriskConnection.java | 16 +
.../camel/component/asterisk/AsteriskEndpoint.java | 19 +-
.../camel/component/asterisk/AsteriskProducer.java | 20 +-
.../asterisk/AsteriskProducerFakeServerTest.java | 251 ++++++
.../camel-azure/camel-azure-cosmosdb/pom.xml | 5 +
.../src/main/docs/azure-cosmosdb-component.adoc | 13 +-
.../component/azure/cosmosdb/CosmosDbConsumer.java | 62 +-
.../cosmosdb/CosmosDbConsumerHealthCheck.java | 87 ++
.../CosmosDbConsumerHealthCheckRegistryTest.java | 194 +++++
.../cosmosdb/CosmosDbConsumerHealthCheckTest.java | 203 +++++
...erchantAccountGatewayEndpointConfiguration.java | 2 +-
.../OAuthGatewayEndpointConfiguration.java | 2 +-
.../PaymentMethodGatewayEndpointConfiguration.java | 2 +-
.../TransactionGatewayEndpointConfiguration.java | 2 +-
.../camel/component/braintree/braintree.json | 8 +-
.../component/cassandra/CassandraProducer.java | 3 -
components/camel-chaos/src/main/docs/chaos.adoc | 16 +-
.../clickhouse/ClickHouseEndpointConfigurer.java | 6 +
.../clickhouse/ClickHouseEndpointUriFactory.java | 3 +-
.../camel/component/clickhouse/clickhouse.json | 13 +-
.../src/main/docs/clickhouse-component.adoc | 14 +
.../component/clickhouse/ClickHouseConstants.java | 8 +-
.../component/clickhouse/ClickHouseEndpoint.java | 17 +-
.../component/clickhouse/ClickHouseProducer.java | 20 +-
.../clickhouse/ClickHouseProducerTest.java | 73 +-
.../camel/component/cxf/common/CXFTestSupport.java | 5 -
.../cxf/jaxrs/CxfRsSpringGlobalSslProducer.xml | 96 ---
.../cxf/jaxrs/CxfRsSpringSslAsyncProducer.xml | 96 ---
.../component/cxf/jaxrs/CxfRsSpringSslProducer.xml | 96 ---
.../cxf/jaxrs/CxfRsGlobalSslProducerTest.java | 24 +-
.../cxf/jaxrs/CxfRsSslAsyncProducerTest.java | 24 +-
.../component/cxf/jaxrs/CxfRsSslProducerTest.java | 24 +-
.../cxf/jaxrs/CxfRsSpringGlobalSslProducer.xml | 6 +-
.../cxf/jaxrs/CxfRsSpringSslAsyncProducer.xml | 6 +-
.../component/cxf/jaxrs/CxfRsSpringSslProducer.xml | 6 +-
.../camel/component/cxf/ssl/SslGlobalTest.java | 24 +-
.../apache/camel/component/cxf/ssl/SslTest.java | 38 +-
.../camel/component/cxf/CxfGlobalSslContext.xml | 4 +-
.../apache/camel/component/cxf/CxfSslContext.xml | 4 +-
.../org/apache/camel/component/dhis2/dhis2.json | 4 +-
.../src/main/docs/dhis2-component.adoc | 10 +
.../camel/component/dhis2/Dhis2Consumer.java | 13 +
.../camel/component/dhis2/Dhis2Endpoint.java | 26 +-
.../camel/component/dhis2/Dhis2Producer.java | 35 +-
.../camel/component/dhis2/Dhis2BodyTest.java | 186 ++++
components/camel-docker/pom.xml | 14 +
.../org/apache/camel/component/docker/docker.json | 16 +-
.../src/main/docs/docker-component.adoc | 38 +
.../component/docker/DockerClientProfile.java | 9 +-
.../component/docker/DockerConfiguration.java | 14 +-
.../camel/component/docker/DockerConstants.java | 11 +-
.../camel/component/docker/DockerEndpoint.java | 38 +-
.../docker/consumer/DockerEventsConsumer.java | 5 +-
.../docker/producer/AsyncDockerProducer.java | 79 +-
.../component/docker/DockerClientProfileTest.java | 25 +
.../component/docker/DockerConfigurationTest.java | 27 +
.../docker/consumer/DockerEventsConsumerTest.java | 15 +
.../docker/producer/AsyncDockerProducerTest.java | 284 ++++++
.../component/duckdb/DuckDbEndpointConfigurer.java | 6 +
.../component/duckdb/DuckDbEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/duckdb/duckdb.json | 5 +-
.../src/main/docs/duckdb-component.adoc | 21 +-
.../camel/component/duckdb/DuckDbConstants.java | 6 +-
.../camel/component/duckdb/DuckDbEndpoint.java | 23 +-
.../camel/component/duckdb/DuckDbProducer.java | 4 +-
.../camel/component/duckdb/DuckDbProducerTest.java | 78 +-
.../rest/client/elasticsearch-rest-client.json | 2 +-
.../docs/elasticsearch-rest-client-component.adoc | 31 +-
.../client/ElasticsearchRestClientEndpoint.java | 14 +-
.../client/ElasticsearchRestClientProducer.java | 23 +-
.../ElasticsearchRestClientProducerBodyTest.java | 189 ++++
.../ElasticsearchActionRequestConverterLoader.java | 8 +
.../apache/camel/component/es/elasticsearch.json | 2 +-
.../src/main/docs/elasticsearch-component.adoc | 31 +-
.../camel/component/es/ElasticsearchEndpoint.java | 30 +-
.../camel/component/es/ElasticsearchProducer.java | 24 +-
.../ElasticsearchActionRequestConverter.java | 114 ++-
.../es/ElasticsearchProducerBodyTest.java | 339 ++++++++
.../ElasticsearchActionRequestConverterTest.java | 133 +++
.../apache/camel/component/geocoder/geocoder.json | 2 +-
.../src/main/docs/geocoder-component.adoc | 2 +
.../camel/component/geocoder/GeoCoderEndpoint.java | 4 +-
.../geocoder/GeoCoderNominatimProducer.java | 25 +-
.../geocoder/GeoCoderNominatimAddressTest.java | 11 +-
.../component/geocoder/GeoCoderNominatimTest.java | 10 +-
.../geocoder/GeoCoderNominatimTestSupport.java | 84 ++
.../geocoder/GeoCoderNominatimZeroResultsTest.java | 81 ++
.../test/resources/nominatim/reverse-sevilla.json | 1 +
.../nominatim/search-calle-marie-curie.json | 1 +
.../calendar/CalendarAclEndpointConfiguration.java | 2 +-
.../CalendarCalendarListEndpointConfiguration.java | 2 +-
.../CalendarChannelsEndpointConfiguration.java | 2 +-
.../CalendarEventsEndpointConfiguration.java | 2 +-
.../CalendarSettingsEndpointConfiguration.java | 2 +-
.../component/google/calendar/google-calendar.json | 10 +-
.../drive/DriveChangesEndpointConfiguration.java | 2 +-
.../drive/DriveChannelsEndpointConfiguration.java | 2 +-
.../drive/DriveFilesEndpointConfiguration.java | 2 +-
.../camel/component/google/drive/google-drive.json | 6 +-
.../GmailUsersMessagesEndpointConfiguration.java | 2 +-
.../camel/component/google/mail/google-mail.json | 2 +-
.../SheetsSpreadsheetsEndpointConfiguration.java | 2 +-
...etsSpreadsheetsValuesEndpointConfiguration.java | 2 +-
.../component/google/sheets/google-sheets.json | 4 +-
.../org/apache/camel/component/grpc/grpc.json | 2 +-
.../camel-grpc/src/main/docs/grpc-component.adoc | 10 +
.../apache/camel/component/grpc/GrpcEndpoint.java | 6 +-
.../component/grpc/server/GrpcMethodHandler.java | 101 ++-
.../server/GrpcRequestAbstractStreamObserver.java | 23 +
.../GrpcRequestAggregationStreamObserver.java | 9 +-
.../GrpcRequestPropagationStreamObserver.java | 9 +-
.../component/grpc/GrpcConsumerReplyTypeTest.java | 283 ++++++
components/camel-hashicorp-vault/pom.xml | 6 +
.../component/hashicorp/vault/hashicorp-vault.json | 2 +-
.../src/main/docs/hashicorp-vault-component.adoc | 9 +-
.../hashicorp/vault/HashicorpVaultEndpoint.java | 10 +-
.../hashicorp/vault/HashicorpVaultProducer.java | 96 ++-
.../vault/HashicorpVaultPropertiesFunction.java | 17 +-
.../vault/HashicorpVaultProducerTest.java | 203 +++++
.../HashicorpVaultPropertiesFunctionTest.java | 21 +
.../component/hazelcast/list/hazelcast-list.json | 2 +-
.../component/hazelcast/map/hazelcast-map.json | 2 +-
.../hazelcast/pncounter/hazelcast-pncounter.json | 3 +
.../component/hazelcast/queue/hazelcast-queue.json | 4 +-
.../component/hazelcast/set/hazelcast-set.json | 2 +-
.../src/main/docs/hazelcast-list-component.adoc | 3 +-
.../src/main/docs/hazelcast-map-component.adoc | 30 +-
.../main/docs/hazelcast-multimap-component.adoc | 32 +-
.../main/docs/hazelcast-pncounter-component.adoc | 42 +-
.../src/main/docs/hazelcast-queue-component.adoc | 7 +
.../docs/hazelcast-replicatedmap-component.adoc | 26 +-
.../main/docs/hazelcast-ringbuffer-component.adoc | 8 +-
.../src/main/docs/hazelcast-set-component.adoc | 2 +-
.../component/hazelcast/HazelcastConstants.java | 2 +-
.../hazelcast/HazelcastDefaultProducer.java | 11 +-
.../hazelcast/list/HazelcastListEndpoint.java | 4 +-
.../hazelcast/list/HazelcastListProducer.java | 8 +-
.../hazelcast/listener/CamelMapListener.java | 5 +
.../hazelcast/listener/MapEntryListener.java | 3 +-
.../hazelcast/map/HazelcastMapEndpoint.java | 7 +-
.../pncounter/HazelcastPNCounterProducer.java | 6 +-
.../hazelcast/queue/HazelcastQueueEndpoint.java | 14 +-
.../hazelcast/queue/HazelcastQueueProducer.java | 30 +-
.../hazelcast/seda/HazelcastSedaProducer.java | 8 +
.../hazelcast/set/HazelcastSetEndpoint.java | 2 +-
.../hazelcast/set/HazelcastSetProducer.java | 4 +-
.../hazelcast/HazelcastMapConsumerExpiredTest.java | 96 +++
.../hazelcast/HazelcastProducerChecksTest.java | 202 +++++
.../hazelcast/HazelcastQueueProducerTest.java | 11 +-
.../camel-hl7/src/main/docs/hl7-dataformat.adoc | 31 +-
.../apache/camel/component/hl7/HL7MLLPCodec.java | 14 +
.../apache/camel/component/hl7/HL7MLLPConfig.java | 7 +-
.../apache/camel/component/hl7/HL7MLLPDecoder.java | 141 ++-
.../hl7/HL7MLLPDecoderMaxFrameLengthTest.java | 291 +++++++
.../hl7/HL7MLLPMinaMaxFrameLengthRouteTest.java | 89 ++
.../camel/component/ignite/cache/ignite-cache.json | 6 +-
.../component/ignite/compute/ignite-compute.json | 4 +-
.../camel/component/ignite/idgen/ignite-idgen.json | 2 +-
.../camel/component/ignite/queue/ignite-queue.json | 2 +-
.../src/main/docs/ignite-cache-component.adoc | 6 +-
.../src/main/docs/ignite-compute-component.adoc | 3 +
.../src/main/docs/ignite-idgen-component.adoc | 4 +
.../src/main/docs/ignite-queue-component.adoc | 3 +
.../src/main/docs/ignite-set-component.adoc | 3 +
.../cache/IgniteCacheContinuousQueryConsumer.java | 9 +-
.../ignite/cache/IgniteCacheEndpoint.java | 17 +-
.../ignite/cache/IgniteCacheProducer.java | 31 +-
.../ignite/compute/IgniteComputeEndpoint.java | 15 +-
.../ignite/compute/IgniteComputeProducer.java | 75 +-
.../ignite/idgen/IgniteIdGenEndpoint.java | 6 +-
.../ignite/idgen/IgniteIdGenProducer.java | 31 +-
.../ignite/queue/IgniteQueueEndpoint.java | 8 +-
.../ignite/queue/IgniteQueueProducer.java | 33 +-
.../component/ignite/set/IgniteSetProducer.java | 33 +-
.../ignite/IgniteCacheContinuousQueryTest.java | 21 +
.../camel/component/ignite/IgniteCacheTest.java | 68 ++
.../camel/component/ignite/IgniteComputeTest.java | 63 +-
.../camel/component/ignite/IgniteIdGenTest.java | 44 +
.../camel/component/ignite/IgniteQueueTest.java | 29 +
.../camel/component/ignite/IgniteSetTest.java | 28 +
.../ignite/TestIgniteComputeResources.java | 26 +
.../apache/camel/component/influxdb/influxdb.json | 4 +-
.../src/main/docs/influxdb-component.adoc | 12 +
.../camel/component/influxdb/InfluxDbEndpoint.java | 20 +-
.../camel/component/influxdb/InfluxDbProducer.java | 31 +-
.../converters/CamelInfluxDbConverters.java | 12 +-
.../influxdb/InfluxDbProducerOperationTest.java | 102 +++
.../influxdb/InfluxDbProducerQueryErrorTest.java | 138 +++
.../converters/CamelInfluxDbConverterTest.java | 27 +
.../camel/component/influxdb2/influxdb2.json | 2 +-
.../src/main/docs/influxdb2-component.adoc | 17 +
.../component/influxdb2/InfluxDb2Endpoint.java | 59 +-
.../component/influxdb2/InfluxDb2Producer.java | 35 +-
.../converters/CamelInfluxDb2Converters.java | 13 +-
.../influxdb2/InfluxDb2EndpointStartupTest.java | 247 ++++++
.../component/influxdb2/InfluxDb2ProducerTest.java | 4 +-
.../InfluxDb2ProducerWriteFailureTest.java | 94 ++
.../converters/CamelInfluxDbConverterTest.java | 27 +
.../src/main/docs/jcache-component.adoc | 2 +
.../camel/component/jcache/JCacheProducer.java | 6 +
.../component/jcache/JCacheProducerPutTest.java | 22 +
.../jgroups/raft/JGroupsRaftAbstractTest.java | 20 +
.../raft/JGroupsRaftComponentConfiguredTest.java | 3 +-
.../raft/JGroupsRaftComponentDefaultTest.java | 3 +-
.../jgroups/raft/JGroupsRaftEndpointTest.java | 3 +-
.../component/jgroups/raft/RaftNodesState.java | 40 +
.../cluster/JGroupsRaftClusterAbstractTest.java | 6 +
.../component/jpa/JpaComponentConfigurer.java | 2 +-
.../org/apache/camel/component/jpa/jpa.json | 4 +-
.../camel-jpa/src/main/docs/jpa-component.adoc | 26 +-
.../apache/camel/component/jpa/JpaComponent.java | 8 +-
.../apache/camel/component/jpa/JpaConstants.java | 3 +-
.../apache/camel/component/jpa/JpaEndpoint.java | 6 +-
.../org/apache/camel/component/jpa/JpaHelper.java | 40 +
.../apache/camel/component/jpa/JpaProducer.java | 13 +-
.../idempotent/jpa/JpaMessageIdRepository.java | 8 +-
.../keyvalue/jpa/JpaKeyValueRepository.java | 3 +-
.../camel/component/jpa/JpaComponentTest.java | 152 ++++
.../idempotent/jpa/JpaMessageIdRepositoryTest.java | 45 +
.../JpaProducerWithQueryParametersHeaderTest.java | 16 +-
.../keyvalue/jpa/JpaKeyValueRepositoryTest.java | 8 +
.../camel/component/kafka/KafkaConstants.java | 19 +
components/camel-kafka/pom.xml | 23 +
.../component/kafka/KafkaComponentConfigurer.java | 6 +
.../component/kafka/KafkaEndpointConfigurer.java | 6 +
.../component/kafka/KafkaEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/kafka/kafka.json | 482 +++++------
.../camel-kafka/src/main/docs/kafka-component.adoc | 159 +++-
.../camel/component/kafka/KafkaConfiguration.java | 25 +
.../camel/component/kafka/KafkaConsumer.java | 184 +++-
.../camel/component/kafka/KafkaProducer.java | 331 ++++++-
.../kafka/KafkaTransactionSynchronization.java | 210 ++++-
.../kafka/consumer/AbstractCommitManager.java | 6 +-
.../component/kafka/consumer/CommitManagers.java | 5 +
.../kafka/consumer/DefaultKafkaManualCommit.java | 15 +
.../kafka/consumer/KafkaExactlyOnceMetadata.java | 311 +++++++
.../kafka/consumer/KafkaManualCommitFactory.java | 19 +
.../kafka/consumer/NoopCommitManager.java | 16 +-
.../batching/KafkaRecordBatchingProcessor.java | 24 +-
.../streaming/KafkaRecordStreamingProcessor.java | 602 +++++++++++++
.../KafkaRecordStreamingProcessorFacade.java | 16 +
.../producer/support/KafkaProducerCallBack.java | 13 +
.../component/kafka/KafkaConsumerStopTest.java | 5 +-
.../kafka/KafkaConsumerSuspendResumeTest.java | 5 +-
.../kafka/KafkaExactlyOnceConfigurationTest.java | 171 ++++
.../camel/component/kafka/KafkaProducerTest.java | 374 ++++++++
.../kafka/KafkaTransactionSynchronizationTest.java | 331 +++++++
.../consumer/KafkaExactlyOnceMetadataTest.java | 282 ++++++
.../KafkaRecordStreamingProcessorTest.java | 265 ++++++
.../kafka/integration/KafkaExactlyOnceIT.java | 744 ++++++++++++++++
.../integration/KafkaExactlyOnceITSupport.java | 256 ++++++
.../integration/KafkaExactlyOnceRebalanceIT.java | 188 ++++
.../integration/KafkaExactlyOnceRegressionIT.java | 952 +++++++++++++++++++++
.../org/apache/camel/component/ldif/ldif.json | 4 +-
.../camel-ldif/src/main/docs/ldif-component.adoc | 26 +-
.../apache/camel/component/ldif/LdifEndpoint.java | 10 +-
.../apache/camel/component/ldif/LdifProducer.java | 82 +-
.../camel/component/ldif/LdifConnectionTest.java | 198 +++++
.../apache/camel/component/ldif/LdifModDnTest.java | 4 +
.../apache/camel/component/ldif/LdifRouteIT.java | 36 +-
.../org/apache/camel/component/mina/mina.json | 8 +-
.../camel-mina/src/main/docs/mina-component.adoc | 18 +-
.../camel/component/mina/MinaConfiguration.java | 4 +-
.../apache/camel/component/mina/MinaConsumer.java | 61 +-
.../apache/camel/component/mina/MinaEndpoint.java | 22 +-
.../apache/camel/component/mina/MinaProducer.java | 13 +-
.../component/mina/MinaConsumerReplyTest.java | 146 ++++
.../camel/component/mina/MinaSyncFalseTest.java | 113 +++
.../org/apache/camel/component/mllp/mllp.json | 2 +-
.../camel-mllp/src/main/docs/mllp-component.adoc | 5 +-
.../apache/camel/component/mllp/MllpEndpoint.java | 8 +-
.../component/mllp/MllpTcpClientProducer.java | 33 +-
.../MllpTcpClientProducerBodyConversionTest.java | 143 ++++
.../component/mongodb/gridfs/mongodb-gridfs.json | 8 +-
.../src/main/docs/mongodb-gridfs-component.adoc | 34 +-
.../component/mongodb/gridfs/GridFsConstants.java | 6 +-
.../component/mongodb/gridfs/GridFsConsumer.java | 137 ++-
.../component/mongodb/gridfs/GridFsEndpoint.java | 15 +-
.../component/mongodb/gridfs/GridFsProducer.java | 22 +-
.../gridfs/GridFsConsumerTimestampTest.java | 291 ++++++-
.../mongodb/gridfs/GridFsProducerTest.java | 129 +++
.../gridfs/integration/GridFsConsumerIT.java | 1 +
.../integration/GridFsProducerOperationsIT.java | 19 +
.../camel/component/netty/http/netty-http.json | 2 +-
.../netty/http/DefaultNettyHttpBinding.java | 23 +-
.../netty/http/HttpClientInitializerFactory.java | 2 +-
.../component/netty/http/NettyHttpComponent.java | 5 +-
.../component/netty/http/NettyHttpEndpoint.java | 21 +-
.../component/netty/http/NettyHttpHelper.java | 2 +-
.../netty/http/ManagedNettyEndpointTest.java | 5 +-
.../NettyHttpEndpointDifferentOptionsTest.java | 85 ++
.../netty/http/NettyHttpProducerSyncFalseTest.java | 59 ++
.../netty/http/NettyHttpReplyBodyTest.java | 164 ++++
.../camel-netty/src/main/docs/netty-component.adoc | 2 +-
.../camel/component/netty/NettyProducer.java | 22 +-
.../netty/NettyProducerSyncFalseReplyTest.java | 14 +
components/camel-observability-services/pom.xml | 2 +-
.../resources/observability-services.json | 2 +-
.../src/main/docs/observability-services.adoc | 2 +-
.../apache/camel/component/olingo4/olingo4.json | 4 +-
.../camel/component/olingo4/Olingo4Consumer.java | 7 +-
.../camel/component/olingo4/Olingo4Endpoint.java | 15 +-
.../camel/component/olingo4/Olingo4Index.java | 24 +-
.../olingo4/Olingo4ComponentConsumerTest.java | 27 +
.../olingo4/Olingo4ComponentProducerTest.java | 28 +
.../camel/component/olingo4/Olingo4IndexTest.java | 124 +++
.../OpensearchActionRequestConverterLoader.java | 8 +
.../camel/component/opensearch/opensearch.json | 2 +-
.../src/main/docs/opensearch-component.adoc | 31 +-
.../component/opensearch/OpensearchEndpoint.java | 30 +-
.../component/opensearch/OpensearchProducer.java | 24 +-
.../OpensearchActionRequestConverter.java | 135 ++-
.../opensearch/OpensearchProducerBodyTest.java | 338 ++++++++
.../OpensearchActionRequestConverterTest.java | 133 +++
.../metrics/opentelemetry-metrics.json | 4 +-
.../main/docs/opentelemetry-metrics-component.adoc | 2 +
.../opentelemetry/metrics/CounterProducer.java | 16 +
.../metrics/OpenTelemetryConstants.java | 4 +-
.../opentelemetry/metrics/CounterRouteTest.java | 97 +++
.../component/springai/chat/spring-ai-chat.json | 2 +-
.../src/main/docs/spring-ai-chat-component.adoc | 12 +
.../springai/chat/SpringAiChatEndpoint.java | 16 +-
.../springai/chat/SpringAiChatProducer.java | 163 +++-
.../chat/SpringAiChatBodyHandlingTest.java | 330 +++++++
.../springai/embeddings/spring-ai-embeddings.json | 4 +-
.../main/docs/spring-ai-embeddings-component.adoc | 6 +-
.../embeddings/SpringAiEmbeddingsEndpoint.java | 10 +-
.../embeddings/SpringAiEmbeddingsProducer.java | 25 +-
.../SpringAiEmbeddingsComponentTest.java | 57 ++
.../vectorstore/spring-ai-vector-store.json | 6 +-
.../docs/spring-ai-vector-store-component.adoc | 31 +-
.../vectorstore/SpringAiVectorStoreEndpoint.java | 20 +-
.../vectorstore/SpringAiVectorStoreHeaders.java | 7 +-
.../vectorstore/SpringAiVectorStoreProducer.java | 170 ++--
.../SpringAiVectorStoreComponentTest.java | 152 ++++
.../src/main/docs/spring-ldap-component.adoc | 3 +-
.../component/springldap/SpringLdapProducer.java | 10 +-
.../springldap/SpringLdapProducerTest.java | 41 +
.../sql/stored/SqlFunctionDataSourceTest.java | 3 +-
.../camel/component/statestore/state-store.json | 4 +-
.../src/main/docs/state-store-component.adoc | 9 +
.../component/statestore/StateStoreEndpoint.java | 10 +-
.../component/statestore/StateStoreProducer.java | 33 +-
.../StateStoreSpooledStreamBodyTest.java | 75 ++
.../statestore/StateStoreStreamBodyTest.java | 241 ++++++
components/camel-stitch/pom.xml | 6 +
.../org/apache/camel/component/stitch/stitch.json | 2 +-
.../src/main/docs/stitch-component.adoc | 3 +-
.../camel/component/stitch/StitchEndpoint.java | 3 +-
.../component/stitch/client/StitchClientImpl.java | 2 +
.../stitch/client/models/StitchMessage.java | 16 +-
.../stitch/client/models/StitchRequestBody.java | 14 +-
.../stitch/client/StitchClientImplTest.java | 124 +++
.../stitch/client/models/StitchMessageTest.java | 35 +
.../client/models/StitchRequestBodyTest.java | 35 +
.../org/apache/camel/component/web3j/web3j.json | 6 +-
.../camel/component/web3j/Web3jConfiguration.java | 11 +-
.../camel/component/web3j/Web3jConsumer.java | 24 +-
.../camel/component/web3j/Web3jEndpoint.java | 8 +-
.../camel/component/web3j/Web3jProducer.java | 18 +-
.../camel/component/web3j/Web3jConsumerTest.java | 126 +++
.../camel/component/web3j/Web3jProducerTest.java | 61 +-
.../xchange/XChangeConvertersLoader.java} | 30 +-
.../apache/camel/component/xchange/xchange.json | 4 +-
.../services/org/apache/camel/TypeConverterLoader | 2 +
.../src/main/docs/xchange-component.adoc | 22 +
.../camel/component/xchange/XChangeComponent.java | 13 +
.../component/xchange/XChangeConfiguration.java | 29 +-
.../camel/component/xchange/XChangeConverters.java | 56 ++
.../camel/component/xchange/XChangeEndpoint.java | 11 +-
.../xchange/XChangeCurrencyConversionTest.java | 170 ++++
.../org/apache/camel/component/xmpp/xmpp.json | 2 +-
.../camel-xmpp/src/main/docs/xmpp-component.adoc | 6 +
.../apache/camel/component/xmpp/XmppConsumer.java | 14 +-
.../apache/camel/component/xmpp/XmppEndpoint.java | 11 +-
.../xmpp/XmppConsumerParticipantTest.java | 114 +++
.../zendesk/ZendeskEndpointConfiguration.java | 2 +-
.../apache/camel/component/zendesk/zendesk.json | 2 +-
.../camel/component/zookeeper/zookeeper.json | 8 +-
.../src/main/docs/zookeeper-component.adoc | 15 +-
.../zookeeper/ZooKeeperConfiguration.java | 3 +-
.../component/zookeeper/ZooKeeperEndpoint.java | 10 +-
.../component/zookeeper/ZooKeeperProducer.java | 121 +--
.../camel/component/zookeeper/ZooKeeperUtils.java | 13 +-
.../component/zookeeper/ZooKeeperProducerTest.java | 230 +++++
.../camel/impl/converter/ArrayTypeConverter.java | 37 +-
.../impl/converter/CoreTypeConverterRegistry.java | 12 +-
.../camel/impl/DefaultDumpRoutesStrategy.java | 2 +
.../apache/camel/processor/MulticastProcessor.java | 50 +-
.../processor/errorhandler/NoErrorHandler.java | 80 +-
.../errorhandler/RedeliveryErrorHandler.java | 23 +
.../impl/DefaultDumpRoutesStrategyOutputTest.java | 60 ++
.../converter/CoreTypeConverterRegistryTest.java | 71 ++
...pervisingRouteControllerMulticastSplitTest.java | 195 +++++
.../NoErrorHandlerProcessorThrowsTest.java | 418 +++++++++
.../RouteStopCutOffCallerRouteTest.java | 169 ++++
.../errorhandler/RouteStopCutOffLogNestedTest.java | 253 ++++++
.../errorhandler/RouteStopCutOffLogTest.java | 116 ++-
.../java/org/apache/camel/util/SecurityUtils.java | 6 +
design/chaos.adoc | 28 +-
.../modules/ROOT/attachments/security-model.yaml | 2 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 34 +
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 34 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 671 ++++++++++++++-
.../modules/ROOT/pages/camel-jbang-mcp.adoc | 61 +-
.../ROOT/pages/camel-jbang-tui-local-models.adoc | 7 +-
.../modules/ROOT/pages/security-model.adoc | 18 +-
.../cli/connector/FileCliConnectorTransport.java | 9 +-
.../connector/FileCliConnectorTransportTest.java | 12 +
.../dsl/DockerComponentBuilderFactory.java | 13 +-
.../dsl/HuggingfaceComponentBuilderFactory.java | 43 +
.../dsl/KafkaComponentBuilderFactory.java | 26 +
.../component/dsl/MinaComponentBuilderFactory.java | 5 +-
.../dsl/Neo4jComponentBuilderFactory.java | 6 +-
.../dsl/Web3jComponentBuilderFactory.java | 8 +-
.../dsl/ZookeeperComponentBuilderFactory.java | 2 +
.../builder/endpoint/EndpointHeaderBuilders.java | 14 +
.../builder/endpoint/StaticEndpointBuilders.java | 22 +-
.../dsl/ClickHouseEndpointBuilderFactory.java | 49 +-
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 69 +-
.../endpoint/dsl/DuckDbEndpointBuilderFactory.java | 46 +-
.../endpoint/dsl/GridFsEndpointBuilderFactory.java | 8 +-
.../HazelcastPNCounterEndpointBuilderFactory.java | 37 +
.../dsl/HuggingFaceEndpointBuilderFactory.java | 74 ++
.../dsl/InfluxDbEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/JpaEndpointBuilderFactory.java | 1 +
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 138 +++
...angChain4jEmbeddingsEndpointBuilderFactory.java | 2 +-
...LangChain4jWebSearchEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/LdifEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/MinaEndpointBuilderFactory.java | 30 +-
.../endpoint/dsl/Neo4jEndpointBuilderFactory.java | 43 +-
.../dsl/OpenTelemetryEndpointBuilderFactory.java | 4 +-
.../SpringAiVectorStoreEndpointBuilderFactory.java | 7 +-
.../endpoint/dsl/Web3jEndpointBuilderFactory.java | 24 +-
.../endpoint/dsl/XmppEndpointBuilderFactory.java | 14 +-
.../dsl/ZooKeeperEndpointBuilderFactory.java | 4 +
.../camel/dsl/jbang/core/commands/AskTools.java | 43 +-
.../dsl/jbang/core/commands/ai/AppFeatures.java | 20 +
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 2 +-
.../dsl/jbang/core/commands/ai/ToolConfirms.java | 26 +-
.../dsl/jbang/core/commands/ai/ToolGroup.java | 4 +-
.../dsl/jbang/core/commands/ai/ToolGroups.java | 47 +-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 140 ++-
.../dsl/jbang/core/commands/AskToolsTest.java | 49 ++
.../jbang/core/commands/ai/AppFeaturesTest.java | 21 +
.../jbang/core/commands/ai/ToolConfirmsTest.java | 20 +
.../dsl/jbang/core/commands/ai/ToolGroupsTest.java | 32 +
.../jbang/core/commands/ai/ToolRegistryTest.java | 74 ++
.../core/commands/mcp/JbangDevMcpServerTest.java | 5 +-
dsl/camel-jbang/camel-jbang-mcp/pom.xml | 12 +
.../dsl/jbang/core/commands/mcp/RuntimeTools.java | 87 +-
.../mcp/RuntimeToolsChaosSecurityTest.java | 111 +++
.../core/commands/mcp/RuntimeToolsChaosTest.java | 313 +++++++
.../jbang/core/commands/mcp/RuntimeToolsTest.java | 3 +-
.../dsl/jbang/core/commands/tui/TuiToolGroups.java | 9 +-
.../core/commands/tui/AiPanelToolGroupsTest.java | 17 +
parent/pom.xml | 2 +-
.../maven/AbstractApiMethodGeneratorMojo.java | 59 +-
.../ApiJavaSourceComponentGeneratorMojoTest.java | 29 +
.../maven/SignatureWithArgumentNamesTest.java | 72 ++
666 files changed, 26895 insertions(+), 2953 deletions(-)
create mode 100644
components/camel-ai/camel-chatscript/src/test/java/org/apache/camel/component/chatscript/ChatScriptConversationTest.java
create mode 100644
components/camel-ai/camel-chatscript/src/test/java/org/apache/camel/component/chatscript/FakeChatScriptServer.java
create mode 100644
components/camel-ai/camel-huggingface/src/test/java/org/apache/camel/component/huggingface/tasks/ChatHistoryTest.java
create mode 100644
components/camel-ai/camel-kserve/src/test/java/org/apache/camel/component/kserve/KServeProducerBodyTest.java
create mode 100644
components/camel-ai/camel-langchain4j-agent/src/test/java/org/apache/camel/component/langchain4j/agent/LangChain4jAgentContentBodyTest.java
create mode 100644
components/camel-ai/camel-langchain4j-embeddings/src/test/java/org/apache/camel/component/langchain4j/embeddings/LangChain4jEmbeddingsBodyTest.java
create mode 100644
components/camel-ai/camel-langchain4j-web-search/src/test/java/org/apache/camel/component/langchain4j/web/search/LangChain4jWebSearchAdditionalParamsTest.java
create mode 100644
components/camel-ai/camel-langchain4j-web-search/src/test/java/org/apache/camel/component/langchain4j/web/search/LangChain4jWebSearchAutowireTest.java
create mode 100644
components/camel-ai/camel-langchain4j-web-search/src/test/java/org/apache/camel/component/langchain4j/web/search/LangChain4jWebSearchContentTest.java
create mode 100644
components/camel-ai/camel-neo4j/src/test/java/org/apache/camel/component/neo4j/Neo4jProducerBodyTest.java
create mode 100644
components/camel-ai/camel-pgvector/src/test/java/org/apache/camel/component/pgvector/PgVectorVectorBodyTest.java
create mode 100644
components/camel-ai/camel-tensorflow-serving/src/test/java/org/apache/camel/component/tensorflow/serving/TensorFlowServingProducerBodyTest.java
create mode 100644
components/camel-ai/camel-weaviate/src/test/java/org/apache/camel/component/weaviate/WeaviateVectorBodyTest.java
create mode 100644
components/camel-arangodb/src/test/java/org/apache/camel/component/arangodb/ArangoDbProducerTest.java
create mode 100644
components/camel-asterisk/src/test/java/org/apache/camel/component/asterisk/AsteriskProducerFakeServerTest.java
create mode 100644
components/camel-azure/camel-azure-cosmosdb/src/main/java/org/apache/camel/component/azure/cosmosdb/CosmosDbConsumerHealthCheck.java
create mode 100644
components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/CosmosDbConsumerHealthCheckRegistryTest.java
create mode 100644
components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/CosmosDbConsumerHealthCheckTest.java
delete mode 100644
components/camel-cxf/camel-cxf-rest/src/test/resources/org/apache/camel/component/cxf/jaxrs/CxfRsSpringGlobalSslProducer.xml
delete mode 100644
components/camel-cxf/camel-cxf-rest/src/test/resources/org/apache/camel/component/cxf/jaxrs/CxfRsSpringSslAsyncProducer.xml
delete mode 100644
components/camel-cxf/camel-cxf-rest/src/test/resources/org/apache/camel/component/cxf/jaxrs/CxfRsSpringSslProducer.xml
create mode 100644
components/camel-dhis2/camel-dhis2-component/src/test/java/org/apache/camel/component/dhis2/Dhis2BodyTest.java
create mode 100644
components/camel-docker/src/test/java/org/apache/camel/component/docker/producer/AsyncDockerProducerTest.java
create mode 100644
components/camel-elasticsearch-rest-client/src/test/java/org/apache/camel/component/elasticsearch/rest/client/ElasticsearchRestClientProducerBodyTest.java
create mode 100644
components/camel-elasticsearch/src/test/java/org/apache/camel/component/es/ElasticsearchProducerBodyTest.java
create mode 100644
components/camel-geocoder/src/test/java/org/apache/camel/component/geocoder/GeoCoderNominatimTestSupport.java
create mode 100644
components/camel-geocoder/src/test/java/org/apache/camel/component/geocoder/GeoCoderNominatimZeroResultsTest.java
create mode 100644
components/camel-geocoder/src/test/resources/nominatim/reverse-sevilla.json
create mode 100644
components/camel-geocoder/src/test/resources/nominatim/search-calle-marie-curie.json
create mode 100644
components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerReplyTypeTest.java
create mode 100644
components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultProducerTest.java
create mode 100644
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapConsumerExpiredTest.java
create mode 100644
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastProducerChecksTest.java
create mode 100644
components/camel-hl7/src/test/java/org/apache/camel/component/hl7/HL7MLLPDecoderMaxFrameLengthTest.java
create mode 100644
components/camel-hl7/src/test/java/org/apache/camel/component/hl7/HL7MLLPMinaMaxFrameLengthRouteTest.java
create mode 100644
components/camel-influxdb/src/test/java/org/apache/camel/component/influxdb/InfluxDbProducerOperationTest.java
create mode 100644
components/camel-influxdb/src/test/java/org/apache/camel/component/influxdb/InfluxDbProducerQueryErrorTest.java
create mode 100644
components/camel-influxdb2/src/test/java/org/apache/camel/component/influxdb2/InfluxDb2EndpointStartupTest.java
create mode 100644
components/camel-jpa/src/test/java/org/apache/camel/processor/idempotent/jpa/JpaMessageIdRepositoryTest.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/KafkaExactlyOnceMetadata.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaExactlyOnceConfigurationTest.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/consumer/KafkaExactlyOnceMetadataTest.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceIT.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceITSupport.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRebalanceIT.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaExactlyOnceRegressionIT.java
create mode 100644
components/camel-ldif/src/test/java/org/apache/camel/component/ldif/LdifConnectionTest.java
create mode 100644
components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerReplyTest.java
create mode 100644
components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSyncFalseTest.java
create mode 100644
components/camel-mllp/src/test/java/org/apache/camel/component/mllp/MllpTcpClientProducerBodyConversionTest.java
create mode 100644
components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/GridFsProducerTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpEndpointDifferentOptionsTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpProducerSyncFalseTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpReplyBodyTest.java
create mode 100644
components/camel-olingo4/camel-olingo4-component/src/test/java/org/apache/camel/component/olingo4/Olingo4IndexTest.java
create mode 100644
components/camel-opensearch/src/test/java/org/apache/camel/component/opensearch/OpensearchProducerBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ai/camel-spring-ai-chat/src/test/java/org/apache/camel/component/springai/chat/SpringAiChatBodyHandlingTest.java
create mode 100644
components/camel-state-store/camel-state-store/src/test/java/org/apache/camel/component/statestore/StateStoreSpooledStreamBodyTest.java
create mode 100644
components/camel-state-store/camel-state-store/src/test/java/org/apache/camel/component/statestore/StateStoreStreamBodyTest.java
create mode 100644
components/camel-stitch/src/test/java/org/apache/camel/component/stitch/client/StitchClientImplTest.java
create mode 100644
components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerTest.java
copy
components/{camel-ai/camel-langchain4j-agent/src/generated/java/org/apache/camel/component/langchain4j/agent/LangChain4jAgentConverterLoader.java
=>
camel-xchange/src/generated/java/org/apache/camel/component/xchange/XChangeConvertersLoader.java}
(52%)
create mode 100644
components/camel-xchange/src/generated/resources/META-INF/services/org/apache/camel/TypeConverterLoader
create mode 100644
components/camel-xchange/src/main/java/org/apache/camel/component/xchange/XChangeConverters.java
create mode 100644
components/camel-xchange/src/test/java/org/apache/camel/component/xchange/XChangeCurrencyConversionTest.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppConsumerParticipantTest.java
create mode 100644
components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperProducerTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/DefaultDumpRoutesStrategyOutputTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultSupervisingRouteControllerMulticastSplitTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/NoErrorHandlerProcessorThrowsTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/RouteStopCutOffCallerRouteTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/RouteStopCutOffLogNestedTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-mcp/src/test/java/org/apache/camel/dsl/jbang/core/commands/mcp/RuntimeToolsChaosSecurityTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-mcp/src/test/java/org/apache/camel/dsl/jbang/core/commands/mcp/RuntimeToolsChaosTest.java
create mode 100644
tooling/maven/camel-api-component-maven-plugin/src/test/java/org/apache/camel/maven/SignatureWithArgumentNamesTest.java
