This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26171-xchange-currency
in repository https://gitbox.apache.org/repos/asf/camel.git
omit 264e8cdcc7b2 CAMEL-26171: camel-xchange - convert currency and
currency pair text, and fail an endpoint with a method of another service
add adaefd1ae61e CAMEL-26298: camel-mcp-server - camel run --mcp-stdio
starts, and stdout carries the MCP protocol only (#28803)
add 31afb62070f0 CAMEL-26508: camel-netty - with transferExchange the
consumer keeps its own connection headers (#28991)
add 8a1fa14951b4 CAMEL-26172: camel-splunk-hec - send bytes, stream and
file bodies as text, and write the JSON before sending (#28998)
add 44791372edc9 CAMEL-26175: camel-odata - send JSON given as bytes, a
stream or a file as it is, fail an empty CREATE/UPDATE body, and read a
response that is not a JSON object (#29003)
add 7b14a24bcb4b CAMEL-26178: camel-coap - a body that does not convert to
a byte array fails instead of being sent as an empty payload (#29004)
add 9758b07ea6e4 CAMEL-26180: camel-plc4x - fail a write tag that is not a
Map of one address, and fail the exchange of the polling consumer for a tag
that cannot be read (#29007)
add ef1010574448 CAMEL-26186: camel-thrift - fail the call when the
consumer reply is null or does not convert, and map a single producer argument
like a List one (#29011)
add 91c23da3054b CAMEL-26181: camel-tahu - tahu-host gives one exchange
for each Sparkplug message, and tahu-edge publishes a text or bytes body as the
payload body (#29015)
add f42f4878fd80 CAMEL-26193: camel-printer - a body that does not convert
to a stream fails the exchange (#29016)
add 8002509c386f CAMEL-26190: camel-jgroups - a stream or a file body is
sent as its content, and another body that is not Serializable fails with a
hint (#29018)
add a8f899e05c8b CAMEL-26198: camel-ldap - fail clearly when a DirContext
bean was closed or is missing, and fix the embedded ApacheDS of the ITs (#29023)
add 542f006d0055 CAMEL-26206: camel-langchain4j-ingest - text mode ingests
the text of a TextSegment or Document body, and fails a body that is not text
(#29030)
add fce13c13dafc CAMEL-26212: camel-ai-resource - a List body with a
binary mimeType gives the conversion error that names the resource and the
mimeType (#29033)
add d54a633393f9 CAMEL-26209: camel-spring-ai-image - an ImagePrompt body
uses the endpoint options and headers, and an Image with only a URL fails to
convert to bytes (#29034)
add 046bf470fbfc CAMEL-26211: camel-djl - a cv or audio body without a
converter fails as not supported, nlp predictors take bytes and streams, and a
custom model is looked up once (#29037)
add 0f9f085e8b97 CAMEL-26184: camel-quickfix - an InOut consumer replies
only to application messages the route answers, and an InOut producer without
CorrelationCriteria fails before sending (#29013)
add e9dcfa9bebe1 CAMEL-26189: camel-jgroups-raft - a body that does not
convert to bytes fails the exchange, and raftId, channelProperties, raftHandle
and stateMachine are endpoint options (#29017)
add e65523ab3e50 CAMEL-26201: camel-crypto - sign and verify keep a stream
body, verify fails without body, and the key header always wins (#29025)
add de10963e2e64 CAMEL-26510: camel-micrometer - a counter increment or
decrement that does not give a number fails the exchange (#29049)
add d2a45d6c6e27 CAMEL-26196: camel-keycloak - convert a pojoRequest body,
fail a create or delete with a non-2xx status, and close its Response (#29024)
add 38cf7052b2f0 chore: camel-observation - import the OpenTelemetry BOMs
so the test classpath has one OpenTelemetry version (#29048)
add f304ad2cfc49 CAMEL-26451: camel-core - Routing Slip and Dynamic Router
fire the sent event of a step before the next step (#28807)
add c621385e890f CAMEL-26477: camel-support - DefaultThreadPoolFactory:
virtual thread pools honor the remove on cancel policy and the pool size
(#28821)
add 8c0259cd497c CAMEL-26458: camel-disruptor - multipleConsumers:
complete the exchange once when a consumer fails (#29038)
add 48757552dee8 CAMEL-26462: camel-nats - a consumer that stops before
its task subscribes closes the dispatcher of that run (#29042)
add 3c2fbfe07beb CAMEL-26420: camel-core - Simple: the white space around
the prefix and the expression of join is not part of them (#29044)
add a55701fdecae chore: camel-jbang-plugin-tui - fix flaky
MonitorStartupTest and AiCliCommandExecutorTest (#28993)
add d10c0c9d1174 CAMEL-26188: camel-cometd - publish a stream or file body
as its text, and a null body as a JSON null (#29014)
add 719e55846aaf CAMEL-26140: camel-vertx-http - the undertow test server
routes reply with an empty body (#29052)
add bed32b3b5446 CAMEL-26490: docs - add the span attribute upgrade note
to the 4.22.3 and 4.18.6 sections of the upgrade guides on main (#29051)
add ffc272852e6f CAMEL-26204: camel-langchain4j-embeddingstore -
auto-embed a TextSegment body as is and a List body as a batch, fail a Map or
POJO body, and REMOVE takes only a text id (#29029)
add c2ce56cba64c chore(deps): Bump the opentelemetry group across 1
directory with 5 updates (#28992)
add 32d935f59ae6 CAMEL-26460: camel-undertow - a static path next to a
path template: the right route for the base path, and stopping the template
route keeps it (#29039)
add 5551dee680b2 CAMEL-26446: camel-core - RedeliveryErrorHandler: a throw
on the first delivery goes through redelivery, the dead letter channel and
onException, and continues the exchange once (#29040)
add 7e7299cc77fd feat(micrometer): don't lookup at every exchange done
add c4198667c9dd chore(micrometer): add parameter to disable last exchange
setting
add edc1252f3fea chore(main): expose metrics recordLastExchangeTimestamp
parameter
add ad8664a7b4c9 Regen
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 a6dc3c630629 CAMEL-26171: camel-xchange - convert currency and
currency pair text, and fail an endpoint with a method of another service
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 (264e8cdcc7b2)
\
N -- N -- N refs/heads/CAMEL-26171-xchange-currency
(a6dc3c630629)
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/coap+tcp.json | 4 +-
.../org/apache/camel/catalog/components/coap.json | 4 +-
.../apache/camel/catalog/components/coaps+tcp.json | 4 +-
.../org/apache/camel/catalog/components/coaps.json | 4 +-
.../apache/camel/catalog/components/cometd.json | 6 +-
.../apache/camel/catalog/components/cometds.json | 6 +-
.../apache/camel/catalog/components/crypto.json | 4 +-
.../org/apache/camel/catalog/components/dhis2.json | 4 +-
.../org/apache/camel/catalog/components/djl.json | 2 +-
.../apache/camel/catalog/components/docker.json | 6 +-
.../apache/camel/catalog/components/duckdb.json | 5 +-
.../components/elasticsearch-rest-client.json | 2 +-
.../apache/camel/catalog/components/geocoder.json | 2 +-
.../org/apache/camel/catalog/components/grpc.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/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 +-
.../camel/catalog/components/jgroups-raft.json | 18 +-
.../apache/camel/catalog/components/jgroups.json | 2 +-
.../org/apache/camel/catalog/components/jpa.json | 2 +-
.../org/apache/camel/catalog/components/kafka.json | 482 +++++------
.../apache/camel/catalog/components/keycloak.json | 4 +-
.../apache/camel/catalog/components/kserve.json | 2 +-
.../catalog/components/langchain4j-agent.json | 2 +-
.../catalog/components/langchain4j-embeddings.json | 4 +-
.../components/langchain4j-embeddingstore.json | 2 +-
.../catalog/components/langchain4j-ingest.json | 2 +-
.../catalog/components/langchain4j-web-search.json | 8 +-
.../org/apache/camel/catalog/components/ldap.json | 2 +-
.../org/apache/camel/catalog/components/ldif.json | 4 +-
.../org/apache/camel/catalog/components/lpr.json | 2 +-
.../org/apache/camel/catalog/components/mina.json | 4 +-
.../org/apache/camel/catalog/components/mllp.json | 2 +-
.../org/apache/camel/catalog/components/neo4j.json | 26 +-
.../camel/catalog/components/netty-http.json | 4 +-
.../org/apache/camel/catalog/components/netty.json | 4 +-
.../org/apache/camel/catalog/components/odata.json | 6 +-
.../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 +-
.../org/apache/camel/catalog/components/plc4x.json | 2 +-
.../apache/camel/catalog/components/quickfix.json | 4 +-
.../camel/catalog/components/splunk-hec.json | 2 +-
.../camel/catalog/components/spring-ai-chat.json | 2 +-
.../catalog/components/spring-ai-embeddings.json | 4 +-
.../camel/catalog/components/spring-ai-image.json | 4 +-
.../apache/camel/catalog/components/stitch.json | 2 +-
.../apache/camel/catalog/components/tahu-edge.json | 2 +-
.../catalog/components/tensorflow-serving.json | 2 +-
.../apache/camel/catalog/components/thrift.json | 2 +-
.../apache/camel/catalog/components/weaviate.json | 2 +-
.../org/apache/camel/catalog/components/web3j.json | 6 +-
.../apache/camel/catalog/components/zookeeper.json | 8 +-
.../camel/catalog/docs/arangodb-component.adoc | 6 +
.../camel/catalog/docs/asterisk-component.adoc | 9 +
.../camel/catalog/docs/chatscript-component.adoc | 8 +-
.../apache/camel/catalog/docs/coap-component.adoc | 7 +-
.../camel/catalog/docs/crypto-component.adoc | 9 +
.../apache/camel/catalog/docs/dhis2-component.adoc | 10 +
.../apache/camel/catalog/docs/djl-component.adoc | 39 +-
.../camel/catalog/docs/docker-component.adoc | 15 +
.../camel/catalog/docs/duckdb-component.adoc | 21 +-
.../docs/elasticsearch-rest-client-component.adoc | 31 +-
.../camel/catalog/docs/geocoder-component.adoc | 2 +
.../apache/camel/catalog/docs/grpc-component.adoc | 10 +
.../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/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 +
.../camel/catalog/docs/jgroups-component.adoc | 7 +
.../camel/catalog/docs/jgroups-raft-component.adoc | 6 +-
.../apache/camel/catalog/docs/kafka-component.adoc | 159 +++-
.../camel/catalog/docs/keycloak-producer.adoc | 26 +-
.../camel/catalog/docs/kserve-component.adoc | 7 +
.../catalog/docs/langchain4j-agent-multimodal.adoc | 15 +
.../docs/langchain4j-embeddings-component.adoc | 15 +
.../docs/langchain4j-embeddingstore-component.adoc | 18 +-
.../catalog/docs/langchain4j-ingest-component.adoc | 7 +
.../docs/langchain4j-web-search-component.adoc | 18 +-
.../apache/camel/catalog/docs/ldap-component.adoc | 12 +-
.../apache/camel/catalog/docs/ldif-component.adoc | 26 +-
.../org/apache/camel/catalog/docs/main.adoc | 3 +-
.../org/apache/camel/catalog/docs/mcp-server.adoc | 11 +-
.../camel/catalog/docs/micrometer-component.adoc | 3 +
.../apache/camel/catalog/docs/mina-component.adoc | 18 +-
.../apache/camel/catalog/docs/mllp-component.adoc | 5 +-
.../apache/camel/catalog/docs/neo4j-component.adoc | 20 +-
.../apache/camel/catalog/docs/odata-component.adoc | 15 +-
.../camel/catalog/docs/opensearch-component.adoc | 31 +-
.../docs/opentelemetry-metrics-component.adoc | 2 +
.../camel/catalog/docs/pgvector-component.adoc | 4 +-
.../apache/camel/catalog/docs/plc4x-component.adoc | 24 +-
.../camel/catalog/docs/quickfix-component.adoc | 41 +-
.../camel/catalog/docs/simple-functions.adoc | 4 +-
.../camel/catalog/docs/splunk-hec-component.adoc | 4 +
.../catalog/docs/spring-ai-chat-component.adoc | 12 +
.../docs/spring-ai-embeddings-component.adoc | 6 +-
.../catalog/docs/spring-ai-image-component.adoc | 23 +-
.../camel/catalog/docs/spring-ldap-component.adoc | 3 +-
.../camel/catalog/docs/stitch-component.adoc | 3 +-
.../camel/catalog/docs/tahu-edge-component.adoc | 8 +
.../camel/catalog/docs/tahu-host-component.adoc | 15 +-
.../catalog/docs/tensorflow-serving-component.adoc | 9 +
.../camel/catalog/docs/thrift-component.adoc | 7 +
.../camel/catalog/docs/weaviate-component.adoc | 2 +-
.../camel/catalog/docs/zookeeper-component.adoc | 15 +-
.../main/camel-main-configuration-metadata.json | 1 +
.../component/ai/resource/AiResourceExecutor.java | 25 +-
.../ai/resource/AiResourceExecutorTest.java | 38 +
.../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 +++
components/camel-ai/camel-djl/pom.xml | 6 +
.../org/apache/camel/component/djl/djl.json | 2 +-
.../camel-djl/src/main/docs/djl-component.adoc | 39 +-
.../apache/camel/component/djl/DJLEndpoint.java | 22 +-
.../apache/camel/component/djl/DJLProducer.java | 6 +
.../djl/model/AbstractCustomPredictor.java | 75 ++
.../component/djl/model/AbstractPredictor.java | 8 +
.../djl/model/audio/CustomAudioPredictor.java | 31 +-
.../djl/model/audio/ZooAudioPredictor.java | 13 +-
.../djl/model/cv/AbstractCvZooPredictor.java | 13 +-
.../component/djl/model/cv/CustomCvPredictor.java | 31 +-
.../model/cv/CustomImageGenerationPredictor.java | 18 +-
.../djl/model/nlp/AbstractNlpZooPredictor.java | 14 +-
.../djl/model/nlp/CustomNlpPredictor.java | 32 +-
.../model/nlp/CustomQuestionAnswerPredictor.java | 18 +-
.../djl/model/tabular/CustomTabularPredictor.java | 18 +-
.../timeseries/CustomForecastingPredictor.java | 18 +-
.../component/djl/model/PredictorBodyTest.java | 280 ++++++
.../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 +++++
.../embeddingstore/langchain4j-embeddingstore.json | 2 +-
.../docs/langchain4j-embeddingstore-component.adoc | 18 +-
.../LangChain4jEmbeddingStoreEndpoint.java | 23 +-
.../LangChain4jEmbeddingStoreProducer.java | 145 +++-
.../LangChain4jEmbeddingStoreAutoEmbedTest.java | 187 ++++
...ngChain4jEmbeddingStoreBatchOperationsTest.java | 67 ++
.../langchain4j/ingest/langchain4j-ingest.json | 2 +-
.../main/docs/langchain4j-ingest-component.adoc | 7 +
.../ingest/LangChain4jIngestEndpoint.java | 10 +-
.../ingest/LangChain4jIngestProducer.java | 46 +-
.../ingest/LangChain4jIngestProducerTest.java | 81 ++
.../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 ++
components/camel-ai/camel-mcp-server/pom.xml | 5 +
.../camel-mcp-server/src/main/docs/mcp-server.adoc | 11 +-
.../mcp/server/stdio/StdioMcpServerEngine.java | 95 +-
.../mcp/server/stdio/McpStdioHarnessMain.java | 40 +
.../mcp/server/stdio/StdioMcpServerProcessIT.java | 64 +-
.../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 ++++++
.../component/cassandra/CassandraProducer.java | 3 -
.../META-INF/org/apache/camel/coap/coap+tcp.json | 4 +-
.../META-INF/org/apache/camel/coap/coap.json | 4 +-
.../META-INF/org/apache/camel/coap/coaps+tcp.json | 4 +-
.../META-INF/org/apache/camel/coap/coaps.json | 4 +-
.../camel-coap/src/main/docs/coap-component.adoc | 7 +-
.../org/apache/camel/coap/CamelCoapResource.java | 4 +-
.../java/org/apache/camel/coap/CoAPEndpoint.java | 6 +-
.../java/org/apache/camel/coap/CoAPProducer.java | 16 +-
.../camel/coap/CoAPUnconvertibleBodyTest.java | 128 +++
.../org/apache/camel/component/cometd/cometd.json | 6 +-
.../org/apache/camel/component/cometd/cometds.json | 6 +-
.../camel/component/cometd/CometdBinding.java | 30 +-
.../camel/component/cometd/CometdEndpoint.java | 23 +-
.../camel/component/cometd/CometdProducer.java | 4 +-
.../component/cometd/CometdProducerBodyTest.java | 201 +++++
.../org/apache/camel/component/crypto/crypto.json | 4 +-
.../src/main/docs/crypto-component.adoc | 9 +
.../crypto/DigitalSignatureConstants.java | 3 +-
.../component/crypto/DigitalSignatureEndpoint.java | 9 +-
.../processor/DigitalSignatureProcessor.java | 23 +-
.../crypto/processor/VerifyingProcessor.java | 43 +-
.../component/crypto/SignatureStreamBodyTest.java | 182 ++++
.../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 ++++
.../MultipleConsumerSynchronizedExchange.java | 26 +-
...DisruptorMultipleConsumersOnCompletionTest.java | 161 ++++
.../MultipleConsumerSynchronizedExchangeTest.java | 103 +++
components/camel-docker/pom.xml | 14 +
.../org/apache/camel/component/docker/docker.json | 6 +-
.../src/main/docs/docker-component.adoc | 15 +
.../component/docker/DockerConfiguration.java | 2 +-
.../camel/component/docker/DockerConstants.java | 6 +-
.../camel/component/docker/DockerEndpoint.java | 38 +-
.../docker/consumer/DockerEventsConsumer.java | 5 +-
.../docker/producer/AsyncDockerProducer.java | 79 +-
.../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 ++++
.../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 +
.../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 ++++++
.../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 +
.../raft/JGroupsRaftEndpointConfigurer.java | 24 +
.../raft/JGroupsRaftEndpointUriFactory.java | 6 +-
.../camel/component/jgroups/raft/jgroups-raft.json | 18 +-
.../src/main/docs/jgroups-raft-component.adoc | 6 +-
.../jgroups/raft/JGroupsRaftEndpoint.java | 34 +-
.../jgroups/raft/JGroupsRaftProducer.java | 3 +-
.../jgroups/raft/JGroupsRaftEndpointTest.java | 15 +
.../jgroups/raft/JGroupsRaftProducerBodyTest.java | 91 ++
.../jgroups/raft/JGroupsRaftProducerTest.java | 8 +
.../apache/camel/component/jgroups/jgroups.json | 2 +-
.../src/main/docs/jgroups-component.adoc | 7 +
.../camel/component/jgroups/JGroupsEndpoint.java | 11 +-
.../camel/component/jgroups/JGroupsProducer.java | 25 +
.../component/jgroups/JGroupsProducerBodyTest.java | 165 ++++
.../org/apache/camel/component/jpa/jpa.json | 2 +-
.../apache/camel/component/jpa/JpaConstants.java | 3 +-
.../apache/camel/component/jpa/JpaProducer.java | 13 +-
.../JpaProducerWithQueryParametersHeaderTest.java | 16 +-
.../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 +++++++++++++++++++++
.../apache/camel/component/keycloak/keycloak.json | 4 +-
.../src/main/docs/keycloak-producer.adoc | 26 +-
.../camel/component/keycloak/KeycloakEndpoint.java | 15 +-
.../camel/component/keycloak/KeycloakProducer.java | 417 +++++----
...KeycloakProducerPojoRequestAndResponseTest.java | 344 ++++++++
.../component/keycloak/KeycloakProducerTest.java | 10 +
.../org/apache/camel/component/ldap/ldap.json | 2 +-
.../camel-ldap/src/main/docs/ldap-component.adoc | 12 +-
.../apache/camel/component/ldap/LdapEndpoint.java | 7 +-
.../apache/camel/component/ldap/LdapProducer.java | 16 +
.../component/ldap/LdapProducerDirContextTest.java | 187 ++++
.../server/core/integ5/DirectoryExtension.java | 29 -
.../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 +-
.../prometheus/MicrometerPrometheusConfigurer.java | 6 +
.../prometheus/MicrometerPrometheus.java | 15 +
.../src/main/docs/micrometer-component.adoc | 3 +
.../component/micrometer/CounterProducer.java | 16 +
.../MicrometerExchangeEventNotifier.java | 37 +-
.../component/micrometer/CounterRouteTest.java | 110 +++
...angeEventNotifierLastTimestampDisabledTest.java | 72 ++
...eterExchangeEventNotifierLastTimestampTest.java | 133 +++
.../org/apache/camel/component/mina/mina.json | 4 +-
.../camel-mina/src/main/docs/mina-component.adoc | 18 +-
.../apache/camel/component/mina/MinaConsumer.java | 61 +-
.../apache/camel/component/mina/MinaEndpoint.java | 22 +-
.../apache/camel/component/mina/MinaProducer.java | 10 +-
.../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 ++++
.../apache/camel/component/nats/NatsConsumer.java | 73 +-
.../nats/NatsConsumerJetStreamPushStopTest.java | 171 +++-
.../camel/component/netty/http/netty-http.json | 4 +-
.../netty/http/HttpClientInitializerFactory.java | 2 +-
.../component/netty/http/NettyHttpComponent.java | 5 +-
.../component/netty/http/NettyHttpEndpoint.java | 17 +-
.../component/netty/http/NettyHttpHelper.java | 2 +-
.../netty/http/ManagedNettyEndpointTest.java | 5 +-
.../NettyHttpEndpointDifferentOptionsTest.java | 85 ++
.../org/apache/camel/component/netty/netty.json | 4 +-
.../camel/component/netty/NettyConfiguration.java | 11 +-
.../camel/component/netty/NettyPayloadHelper.java | 53 +-
...NettyTransferExchangeConnectionHeadersTest.java | 157 ++++
components/camel-observation/pom.xml | 20 +
.../org/apache/camel/component/odata/odata.json | 6 +-
.../camel-odata/src/main/docs/odata-component.adoc | 15 +-
.../camel/component/odata/ODataConfiguration.java | 2 +-
.../camel/component/odata/ODataEndpoint.java | 25 +-
.../apache/camel/component/odata/ODataHelper.java | 33 +-
.../camel/component/odata/ODataProducer.java | 54 +-
.../camel/component/odata/ODataProducerTest.java | 125 +++
.../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 +++
.../org/apache/camel/component/plc4x/plc4x.json | 2 +-
.../camel-plc4x/src/main/docs/plc4x-component.adoc | 24 +-
.../camel/component/plc4x/Plc4XEndpoint.java | 36 +-
.../component/plc4x/Plc4XPollingConsumer.java | 4 +-
.../camel/component/plc4x/Plc4XProducer.java | 6 +-
.../camel/component/plc4x/Plc4XEndpointTest.java | 76 ++
.../camel/component/plc4x/Plc4XFailureTest.java | 44 +
.../org/apache/camel/component/printer/lpr.json | 2 +-
.../camel/component/printer/PrinterEndpoint.java | 2 +-
.../camel/component/printer/PrinterProducer.java | 4 +-
.../camel/component/printer/PrinterPrintTest.java | 3 +-
.../component/printer/PrinterProducerBodyTest.java | 154 ++++
.../apache/camel/component/quickfixj/quickfix.json | 4 +-
.../src/main/docs/quickfix-component.adoc | 41 +-
.../component/quickfixj/MessageCorrelator.java | 7 +
.../component/quickfixj/QuickfixjConsumer.java | 26 +-
.../component/quickfixj/QuickfixjEndpoint.java | 11 +-
.../component/quickfixj/QuickfixjProducer.java | 2 +-
.../component/quickfixj/QuickfixjConsumerTest.java | 75 +-
.../component/quickfixj/QuickfixjInOutTest.java | 236 +++++
.../QuickfixjProducerCorrelationCleanupTest.java | 18 +
.../component/quickfixj/QuickfixjProducerTest.java | 2 +-
.../camel/component/splunkhec/splunk-hec.json | 2 +-
.../src/main/docs/splunk-hec-component.adoc | 4 +
.../component/splunkhec/SplunkHECEndpoint.java | 7 +-
.../component/splunkhec/SplunkHECProducer.java | 36 +-
.../splunkhec/SplunkHECProducerHttpTest.java | 99 +++
.../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 ++
.../component/springai/image/spring-ai-image.json | 4 +-
.../src/main/docs/spring-ai-image-component.adoc | 23 +-
.../springai/image/SpringAiImageConverter.java | 9 +-
.../springai/image/SpringAiImageEndpoint.java | 10 +-
.../springai/image/SpringAiImageProducer.java | 52 +-
.../springai/image/SpringAiImageConverterTest.java | 98 +++
.../springai/image/SpringAiImageProducerTest.java | 159 ++++
.../src/main/docs/spring-ldap-component.adoc | 3 +-
.../component/springldap/SpringLdapProducer.java | 10 +-
.../springldap/SpringLdapProducerTest.java | 41 +
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/tahu/tahu-edge.json | 2 +-
.../src/main/docs/tahu-edge-component.adoc | 8 +
.../src/main/docs/tahu-host-component.adoc | 15 +-
.../camel/component/tahu/TahuEdgeEndpoint.java | 9 +-
.../component/tahu/TahuEdgePayloadConverter.java | 5 +-
.../camel/component/tahu/TahuEdgeProducer.java | 24 +-
.../camel/component/tahu/TahuHostConsumer.java | 11 +-
.../MultiTahuHostApplicationEventHandler.java | 18 +-
.../camel/component/tahu/FakeMqttBroker.java | 56 +-
.../component/tahu/TahuEdgeProducerBodyTest.java | 156 ++++
.../tahu/TahuHostConsumerMessageTest.java | 107 +++
.../org/apache/camel/component/thrift/thrift.json | 2 +-
.../src/main/docs/thrift-component.adoc | 7 +
.../camel/component/thrift/ThriftEndpoint.java | 4 +-
.../apache/camel/component/thrift/ThriftUtils.java | 60 +-
.../thrift/server/ThriftMethodHandler.java | 40 +-
.../component/thrift/ThriftConsumerReplyTest.java | 176 ++++
.../camel/component/thrift/ThriftUtilsTest.java | 88 ++
.../undertow/handlers/CamelPathHandler.java | 46 +-
.../handlers/CamelPathTemplateHandler.java | 42 +-
.../undertow/handlers/CamelRootHandler.java | 49 +-
.../UndertowPrefixPathAfterTemplatePathTest.java | 70 ++
.../UndertowTemplatePathAndStaticPathTest.java | 197 +++++
.../undertow/handlers/CamelRootHandlerTest.java | 74 ++
.../vertx/http/VertxHttpRequestBodyTypesTest.java | 4 +-
.../http/VertxHttpRequestWithPayloadTest.java | 4 +-
.../vertx/http/VertxHttpSerializedBodyTest.java | 4 +-
.../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 +-
.../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/DefaultDumpRoutesStrategy.java | 2 +
.../modules/languages/pages/simple-functions.adoc | 4 +-
.../language/simple/SimpleFunctionHelper.java | 22 +-
.../simple/functions/JoinFunctionFactory.java | 25 +-
.../org/apache/camel/processor/RoutingSlip.java | 176 ++--
.../processor/errorhandler/NoErrorHandler.java | 80 +-
.../errorhandler/RedeliveryErrorHandler.java | 112 ++-
.../impl/DefaultDumpRoutesStrategyOutputTest.java | 60 ++
.../ScheduledThreadPoolRemoveOnCancelTest.java | 59 ++
.../simple/functions/JoinFunctionFactoryTest.java | 47 +
.../camel/processor/ThreadsKeepAliveTimeTest.java | 3 +
.../NoErrorHandlerProcessorThrowsTest.java | 418 +++++++++
...veryFirstDeliveryProcessorThrowsPooledTest.java | 38 +
...RedeliveryFirstDeliveryProcessorThrowsTest.java | 407 +++++++++
...eryFirstDeliveryProcessorThrowsTestSupport.java | 78 ++
.../DynamicRouterEventNotifierTest.java | 15 +
.../routingslip/RoutingSlipEventNotifierTest.java | 15 +
.../routingslip/RoutingSlipSentEventOrderTest.java | 163 ++++
.../MetricsConfigurationPropertiesConfigurer.java | 7 +
.../camel-main-configuration-metadata.json | 1 +
core/camel-main/src/main/docs/main.adoc | 3 +-
.../camel/main/MetricsConfigurationProperties.java | 23 +
core/camel-support/pom.xml | 27 +
.../camel/support/DefaultThreadPoolFactory.java | 55 +-
...DefaultThreadPoolFactoryVirtualThreadsTest.java | 127 +++
.../java/org/apache/camel/util/SecurityUtils.java | 3 +
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 37 +
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 37 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 689 +++++++++++++++
.../modules/ROOT/pages/threading-model.adoc | 4 +-
.../modules/ROOT/pages/virtual-threads.adoc | 5 +-
.../dsl/KafkaComponentBuilderFactory.java | 26 +
.../dsl/Neo4jComponentBuilderFactory.java | 6 +-
.../dsl/NettyComponentBuilderFactory.java | 8 +-
.../dsl/NettyHttpComponentBuilderFactory.java | 8 +-
.../dsl/Web3jComponentBuilderFactory.java | 8 +-
.../dsl/ZookeeperComponentBuilderFactory.java | 2 +
.../builder/endpoint/EndpointHeaderBuilders.java | 14 +
.../builder/endpoint/StaticEndpointBuilders.java | 26 +-
.../DigitalSignatureEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/DuckDbEndpointBuilderFactory.java | 46 +-
.../HazelcastPNCounterEndpointBuilderFactory.java | 37 +
.../dsl/InfluxDbEndpointBuilderFactory.java | 3 +-
.../dsl/JGroupsRaftEndpointBuilderFactory.java | 279 ++++++
.../endpoint/dsl/JpaEndpointBuilderFactory.java | 1 +
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 138 +++
...angChain4jEmbeddingsEndpointBuilderFactory.java | 2 +-
...LangChain4jWebSearchEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/LdapEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/LdifEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/Neo4jEndpointBuilderFactory.java | 43 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 48 +-
.../dsl/NettyHttpEndpointBuilderFactory.java | 48 +-
.../endpoint/dsl/ODataEndpointBuilderFactory.java | 2 +
.../dsl/OpenTelemetryEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/Web3jEndpointBuilderFactory.java | 24 +-
.../dsl/ZooKeeperEndpointBuilderFactory.java | 4 +
.../apache/camel/dsl/jbang/core/commands/Run.java | 9 +-
.../commands/RunMcpStdioConfigurationTest.java | 58 ++
.../commands/tui/AiCliCommandExecutorTest.java | 4 +
.../jbang/core/commands/tui/BorderRenderTest.java | 3 +
.../core/commands/tui/MonitorStartupTest.java | 12 +-
.../core/commands/tui/ShellPanelLifecycleTest.java | 8 +
parent/pom.xml | 4 +-
686 files changed, 28279 insertions(+), 2900 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-djl/src/main/java/org/apache/camel/component/djl/model/AbstractCustomPredictor.java
create mode 100644
components/camel-ai/camel-djl/src/test/java/org/apache/camel/component/djl/model/PredictorBodyTest.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-coap/src/test/java/org/apache/camel/coap/CoAPUnconvertibleBodyTest.java
create mode 100644
components/camel-cometd/src/test/java/org/apache/camel/component/cometd/CometdProducerBodyTest.java
create mode 100644
components/camel-crypto/src/test/java/org/apache/camel/component/crypto/SignatureStreamBodyTest.java
create mode 100644
components/camel-dhis2/camel-dhis2-component/src/test/java/org/apache/camel/component/dhis2/Dhis2BodyTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorMultipleConsumersOnCompletionTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/MultipleConsumerSynchronizedExchangeTest.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-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-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-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftProducerBodyTest.java
create mode 100644
components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsProducerBodyTest.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-keycloak/src/test/java/org/apache/camel/component/keycloak/KeycloakProducerPojoRequestAndResponseTest.java
create mode 100644
components/camel-ldap/src/test/java/org/apache/camel/component/ldap/LdapProducerDirContextTest.java
create mode 100644
components/camel-ldif/src/test/java/org/apache/camel/component/ldif/LdifConnectionTest.java
create mode 100644
components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/eventnotifier/MicrometerExchangeEventNotifierLastTimestampDisabledTest.java
create mode 100644
components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/eventnotifier/MicrometerExchangeEventNotifierLastTimestampTest.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-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpEndpointDifferentOptionsTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTransferExchangeConnectionHeadersTest.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-printer/src/test/java/org/apache/camel/component/printer/PrinterProducerBodyTest.java
create mode 100644
components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjInOutTest.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-spring-parent/camel-spring-ai/camel-spring-ai-image/src/test/java/org/apache/camel/component/springai/image/SpringAiImageConverterTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ai/camel-spring-ai-image/src/test/java/org/apache/camel/component/springai/image/SpringAiImageProducerTest.java
create mode 100644
components/camel-stitch/src/test/java/org/apache/camel/component/stitch/client/StitchClientImplTest.java
create mode 100644
components/camel-tahu/src/test/java/org/apache/camel/component/tahu/TahuEdgeProducerBodyTest.java
create mode 100644
components/camel-tahu/src/test/java/org/apache/camel/component/tahu/TahuHostConsumerMessageTest.java
create mode 100644
components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftConsumerReplyTest.java
create mode 100644
components/camel-thrift/src/test/java/org/apache/camel/component/thrift/ThriftUtilsTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/UndertowPrefixPathAfterTemplatePathTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/UndertowTemplatePathAndStaticPathTest.java
create mode 100644
components/camel-web3j/src/test/java/org/apache/camel/component/web3j/Web3jConsumerTest.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/ScheduledThreadPoolRemoveOnCancelTest.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/RedeliveryFirstDeliveryProcessorThrowsPooledTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/RedeliveryFirstDeliveryProcessorThrowsTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/RedeliveryFirstDeliveryProcessorThrowsTestSupport.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/routingslip/RoutingSlipSentEventOrderTest.java
create mode 100644
core/camel-support/src/test/java/org/apache/camel/support/DefaultThreadPoolFactoryVirtualThreadsTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/commands/RunMcpStdioConfigurationTest.java
