This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch chore-mariadb-4
in repository https://gitbox.apache.org/repos/asf/camel.git
discard 2a485a132ecf chore(deps): Upgrade mariadb-java-client to 4.0.0
add 8561a9b1ca3d CAMEL-26503: camel-platform-http-vertx - write a number,
boolean, character or enum reply as text (#28984)
add c4762905ce91 chore: camel-clickhouse - treat an empty List body as a
0-row insert (#28986)
add f02b49e1a7c3 chore: camel-zendesk - fix the environment variable names
of the integration test setup (#28988)
add b05201d85057 CAMEL-26119: camel-camunda - read a JSON body as bytes or
a stream, and fail the exchange when an operation fails; the JSON uses
camelCase (#28896)
add 7c13a878cbb4 CAMEL-26220: camel-ibm-watson-discovery - manage
com.ibm.cloud:sdk-core 9.24.3, which works with the Gson of Camel, so query no
longer fails with NoClassDefFoundError for $Gson$Types (#28974)
add 869ea9ad41c0 CAMEL-26223: camel-ibm-watson-speech-to-text - close the
audio stream opened for a File, Path or file consumer body (#28972)
add 8d8976c88250 CAMEL-26222: camel-ibm-watsonx-ai - check the elements of
a List of chat messages, and read a bytes or stream body as text for chat,
embedding and rerank (#28971)
add 70e52ddde700 CAMEL-26268: camel-huaweicloud-obs - putObject needs the
bucket name for a File body too (#28967)
add a72119122ec1 CAMEL-26266: camel-huaweicloud-functiongraph - keep the
whole result when it has no body field, and take a JSON object event as bytes,
a stream or a file (#28965)
add 9f59b88c810f CAMEL-26253: camel-google-secret-manager - createSecret
reads the value before it creates the secret, and takes a CreateSecretRequest
with pojoRequest=true (#28963)
add 98d83cd974de CAMEL-26299: camel-azure-eventgrid - build the CloudEvent
with the data format of the body, so sending no longer fails with a
NullPointerException (#28957)
add 421579fe25f9 CAMEL-26262: camel-alibaba-sls - the putLogs examples
build a LogGroup with a bean instead of setting a text body (#28953)
add 7292654a06e9 CAMEL-26260: camel-alibaba-eventbridge - a byte[], stream
or file body is read as the JSON text of the event, instead of failing (#28951)
add 9ff19010c52c CAMEL-26258: camel-alibaba-kms - encrypt encrypts a
stream or a file as its bytes, so binary plaintext is not corrupted (#28949)
add 52c3e9428891 CAMEL-26257: camel-alibaba-fc - invokeFunction sends a
stream or a file as its bytes, so binary data is not corrupted (#28948)
add 88e4b8603214 chore(deps): Bump io.qdrant:client from 1.19.0 to 1.20.0
(#28938)
add 1d2c682d736c chore(deps): Bump web3j-version from 6.0.0 to 6.1.0
(#28937)
add 8bbf76c5b0c1 chore(deps): Bump io.rest-assured:rest-assured from 6.2.0
to 6.3.0 (#28934)
add 59b40d558335 chore(deps-dev): Bump com.icegreen:greenmail from 2.1.14
to 2.1.15 (#28932)
add c90d761ee127 chore(deps): Bump io.camunda:camunda-client-java from
8.10.4 to 8.10.7 (#28930)
add 262ef0d74e82 chore(deps): Bump quarkus-version from 3.40.1 to 3.40.1.1
(#28929)
add 41f7da961d17 CAMEL-26251: camel-google-bigquery - endpoints use the
connectionFactory of the component, a DDL statement gives no body instead of a
NullPointerException, and a body that is not a row fails a grouped exchange
before any row is inserted (#28970)
add b4d63b7d7206 CAMEL-26269: camel-huaweicloud-smn - publish a Map, a
List or a POJO as JSON, and set the message id in CamelHwCloudSmnMessageId
(#28968)
add 4d6de5df2521 CAMEL-26138: camel-http-common - write a chunked or gzip
Map, List, POJO or number reply, keep a form POST body with
disableStreamCache=true, and mapHttpMessageBody=false leaves the body null
(#28911)
add ac892fc4de6b CAMEL-26243: camel-google-sheets - remove
spreadsheets/developerMetadata, sheets and values, the accessors of
sub-resources that failed with a ClassCastException, and document that
splitResult has no effect (#28959)
add acb8f1cfb325 CAMEL-26242: camel-google-mail - remove
messages/attachments, the accessor of the Attachments sub-resource, which
failed with a ClassCastException (#28958)
add f6e08d43062a CAMEL-26247: camel-azure-functions - send the body as
bytes, add the default Content-Type without the headers map, and fail on an
HTTP error status (#28955)
add 2883080b73c9 CAMEL-26261: camel-alibaba-oss - add the includeBody
option, so the consumer can give the stream of an object instead of reading it
into a byte array (#28952)
add 1743bcb5f98f CAMEL-26259: camel-alibaba-mns - send a byte[], stream or
file body as its bytes, give a binary message as bytes, set the message id and
MD5 as headers, and drop receiveMessage from the operations (#28950)
add 6bf110ff054f CAMEL-26252: camel-google-functions - a failed
callFunction fails the exchange, no body fails with an InvalidPayloadException,
and a Map or POJO body is sent as JSON (#28962)
add 9d9c2e836a13 CAMEL-26432: camel-chaos - error status= for netty-http
(#28811)
add d00414c78996 CAMEL-26250: camel-google-vertexai - generateMultimodal
sends a stream, file or bytes body as media, rawPredict reads bytes, stream and
file bodies as text, and the declared headers are applied or deprecated (#28969)
add 4861336aaf4f CAMEL-26267: camel-huaweicloud-iam - read the JSON of
updateUser and updateGroup from bytes, a stream or a file, and write the
results with the field names of the IAM API (#28966)
add f10e145d3b1e CAMEL-26265: camel-huaweicloud-dms - read the JSON
request from bytes, a stream or a file, and fail on a body that is not the
request (#28964)
add 81d06027f606 CAMEL-26249: camel-google-text-to-speech -
pojoRequest=true runs the operation, and listVoices lists all voices unless
languageCode is set (#28961)
add 403acb0ca8c1 CAMEL-26505: camel-jms / camel-sjms - a body that maps to
no JMS message type fails the exchange instead of being sent as an empty
message (#28987)
add d86e316b04a9 CAMEL-26244: camel-google-drive - drive-files/export, and
drive-files/get and drive-revisions/get with alt=media, give the content of the
file as an InputStream, and FileConverterIT uses drive-files/create (#28960)
add e9b27ef1d7b3 CAMEL-26507: camel-vertx - the producer sends a message
without a body as a null body (#28989)
add 07f5c40033ca CAMEL-26504: camel-netty / camel-netty-http - answer or
close when the reply cannot be built or written, honour allowSerializedHeaders
on the reply (#28985)
add 94e7619f147d chore: camel-launcher - run the distribution ITs in
verify, not with -Dquickly, and in the native exe workflow (#28885)
add e4dc3321370c CAMEL-25674: camel-netty-http - hostnameVerification no
longer breaks client certificates on a consumer (#28871)
add b59a37efd89c CAMEL-26490: camel-telemetry, camel-tracing - present the
http.url, url.path and server.address span attributes like camel.uri (#28867)
add cb848054a7b8 chore(deps): Bump endive-version from 1.1.0 to 1.2.0
(#28926)
add 70288e19ee0f chore(deps): Bump
org.apache.maven.plugins:maven-enforcer-plugin from 3.6.3 to 3.7.0 (#28877)
add de836f4af365 CAMEL-26478: camel-util - BoundedExecutorService: a task
must not wait for a permit it holds itself (#28823)
add c5ddcae3d53b CAMEL-26501: camel-aws-bedrock -
aws-bedrock-agent-runtime sends a Map or JsonNode body as JSON (#28981)
add cc1217629ee1 CAMEL-26470: camel-support - PatternHelper: do not
compile a regular expression for a pattern without metacharacters (#28814)
add 065646714889 CAMEL-26221: camel-ibm-watsonx-data - getAllColumns
parses its response with the managed com.ibm.cloud:sdk-core, and updateTable
takes the table patch as JSON text as well as a Map (#28975)
add 64ab57e4dc34 CAMEL-26254: camel-ibm-secrets-manager - getSecret gives
the Secret for every other secret type, createKVSecret takes a JSON object, and
a Map or a POJO is stored as JSON in an arbitrary secret (#28973)
add 980a01202a31 CAMEL-26248: camel-azure-key-vault - deleteSecret sets
the DeletedSecret as the body, and createSecret stores a Map, a List or a POJO
as JSON (#28956)
add 515378b199b8 CAMEL-26246: camel-azure-cosmosdb - parse the JSON of an
item given as text, bytes, a stream or a file, and fail a List body of the item
operations (#28954)
add 343c0492d0ed [JBANG-IT] Adapt container-only tests to run on host
(#28526)
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 67166f42bfa8 chore(deps): Upgrade mariadb-java-client to 4.0.0
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 (2a485a132ecf)
\
N -- N -- N refs/heads/chore-mariadb-4 (67166f42bfa8)
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:
.github/dependabot.yml | 3 +
.github/workflows/camel-launcher-native-exe.yml | 5 +-
.../catalog/components/alibaba-eventbridge.json | 2 +-
.../camel/catalog/components/alibaba-fc.json | 2 +-
.../camel/catalog/components/alibaba-kms.json | 2 +-
.../camel/catalog/components/alibaba-mns.json | 8 +-
.../camel/catalog/components/alibaba-oss.json | 59 +-
.../apache/camel/catalog/components/arangodb.json | 4 +-
.../apache/camel/catalog/components/asterisk.json | 2 +-
.../catalog/components/atmosphere-websocket.json | 2 +-
.../components/aws-bedrock-agent-runtime.json | 2 +-
.../camel/catalog/components/azure-cosmosdb.json | 4 +-
.../camel/catalog/components/azure-eventgrid.json | 2 +-
.../camel/catalog/components/azure-functions.json | 50 +-
.../camel/catalog/components/azure-key-vault.json | 4 +-
.../apache/camel/catalog/components/camunda.json | 4 +-
.../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 +-
.../catalog/components/google-bigquery-sql.json | 2 +-
.../camel/catalog/components/google-bigquery.json | 2 +-
.../camel/catalog/components/google-drive.json | 9 +-
.../camel/catalog/components/google-functions.json | 4 +-
.../camel/catalog/components/google-mail.json | 6 +-
.../catalog/components/google-secret-manager.json | 4 +-
.../camel/catalog/components/google-sheets.json | 8 +-
.../catalog/components/google-text-to-speech.json | 6 +-
.../camel/catalog/components/google-vertexai.json | 16 +-
.../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/hwcloud-dms.json | 2 +-
.../catalog/components/hwcloud-functiongraph.json | 4 +-
.../camel/catalog/components/hwcloud-iam.json | 4 +-
.../camel/catalog/components/hwcloud-smn.json | 4 +-
.../catalog/components/ibm-secrets-manager.json | 4 +-
.../camel/catalog/components/ibm-watsonx-ai.json | 2 +-
.../camel/catalog/components/ibm-watsonx-data.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 +-
.../org/apache/camel/catalog/components/jetty.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 +-
.../apache/camel/catalog/components/servlet.json | 2 +-
.../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 +-
.../org/apache/camel/catalog/components/vertx.json | 4 +-
.../apache/camel/catalog/components/weaviate.json | 2 +-
.../org/apache/camel/catalog/components/web3j.json | 6 +-
.../apache/camel/catalog/components/zookeeper.json | 8 +-
.../docs/alibaba-eventbridge-component.adoc | 11 +-
.../camel/catalog/docs/alibaba-fc-component.adoc | 7 +
.../camel/catalog/docs/alibaba-kms-component.adoc | 8 +
.../camel/catalog/docs/alibaba-mns-component.adoc | 45 +-
.../camel/catalog/docs/alibaba-oss-component.adoc | 39 +
.../camel/catalog/docs/alibaba-sls-component.adoc | 37 +-
.../camel/catalog/docs/arangodb-component.adoc | 6 +
.../camel/catalog/docs/asterisk-component.adoc | 9 +
.../docs/aws-bedrock-agent-runtime-component.adoc | 7 +-
.../catalog/docs/azure-cosmosdb-component.adoc | 31 +-
.../catalog/docs/azure-eventgrid-component.adoc | 16 +
.../catalog/docs/azure-functions-component.adoc | 17 +
.../catalog/docs/azure-key-vault-component.adoc | 8 +-
.../camel/catalog/docs/camunda-component.adoc | 41 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 35 +-
.../camel/catalog/docs/chatscript-component.adoc | 8 +-
.../camel/catalog/docs/clickhouse-component.adoc | 1 +
.../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 +
.../catalog/docs/google-bigquery-component.adoc | 4 +
.../docs/google-bigquery-sql-component.adoc | 1 +
.../camel/catalog/docs/google-drive-component.adoc | 69 ++
.../catalog/docs/google-functions-component.adoc | 12 +
.../docs/google-secret-manager-component.adoc | 40 +-
.../catalog/docs/google-sheets-component.adoc | 9 +
.../docs/google-text-to-speech-component.adoc | 32 +-
.../catalog/docs/google-vertexai-component.adoc | 74 +-
.../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/hwcloud-dms-component.adoc | 6 +-
.../docs/hwcloud-functiongraph-component.adoc | 15 +
.../camel/catalog/docs/hwcloud-iam-component.adoc | 31 +-
.../camel/catalog/docs/hwcloud-smn-component.adoc | 13 +-
.../docs/ibm-secrets-manager-component.adoc | 70 +-
.../docs/ibm-watson-speech-to-text-component.adoc | 7 +
.../catalog/docs/ibm-watsonx-ai-component.adoc | 13 +
.../catalog/docs/ibm-watsonx-data-component.adoc | 63 +-
.../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/jms-component.adoc | 8 +
.../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 +-
.../camel/catalog/docs/netty-http-component.adoc | 11 +
.../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 +-
.../camel/catalog/docs/platform-http-vertx.adoc | 7 +
.../apache/camel/catalog/docs/plc4x-component.adoc | 24 +-
.../camel/catalog/docs/quickfix-component.adoc | 41 +-
.../camel/catalog/docs/simple-functions.adoc | 4 +-
.../apache/camel/catalog/docs/sjms-component.adoc | 3 +-
.../apache/camel/catalog/docs/sjms2-component.adoc | 3 +-
.../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 +
.../apache/camel/catalog/docs/vertx-component.adoc | 3 +-
.../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 ++++
.../alibaba/eventbridge/alibaba-eventbridge.json | 2 +-
.../main/docs/alibaba-eventbridge-component.adoc | 11 +-
.../eventbridge/AlibabaEventBridgeEndpoint.java | 16 +-
.../eventbridge/AlibabaEventBridgeUtils.java | 42 +-
.../alibaba/eventbridge/PutEventsBodyTest.java | 205 ++++
.../camel/component/alibaba/fc/alibaba-fc.json | 2 +-
.../src/main/docs/alibaba-fc-component.adoc | 7 +
.../camel/component/alibaba/fc/FCEndpoint.java | 8 +-
.../apache/camel/component/alibaba/fc/FCUtils.java | 7 +-
.../alibaba/fc/InvokeFunctionPayloadTest.java | 162 +++
.../camel/component/alibaba/kms/alibaba-kms.json | 2 +-
.../src/main/docs/alibaba-kms-component.adoc | 8 +
.../camel/component/alibaba/kms/KMSEndpoint.java | 9 +-
.../camel/component/alibaba/kms/KMSUtils.java | 14 +-
.../alibaba/kms/EncryptPlaintextTest.java | 170 ++++
.../camel/component/alibaba/mns/alibaba-mns.json | 8 +-
.../src/main/docs/alibaba-mns-component.adoc | 45 +-
.../camel/component/alibaba/mns/MNSConsumer.java | 3 +-
.../camel/component/alibaba/mns/MNSEndpoint.java | 27 +-
.../camel/component/alibaba/mns/MNSProducer.java | 16 +-
.../camel/component/alibaba/mns/MNSUtils.java | 48 +
.../component/alibaba/mns/MNSConsumerBodyTest.java | 118 +++
.../component/alibaba/mns/MNSProducerBodyTest.java | 220 ++++
.../mns/MNSProducerResponseHeadersTest.java | 135 +++
.../mns/MNSReceiveMessageOperationTest.java | 104 ++
.../alibaba/oss/OSSEndpointConfigurer.java | 6 +
.../alibaba/oss/OSSEndpointUriFactory.java | 3 +-
.../camel/component/alibaba/oss/alibaba-oss.json | 59 +-
.../src/main/docs/alibaba-oss-component.adoc | 39 +
.../camel/component/alibaba/oss/OSSConsumer.java | 53 +-
.../camel/component/alibaba/oss/OSSEndpoint.java | 21 +-
.../camel/component/alibaba/oss/OSSUtils.java | 37 +-
.../alibaba/oss/OSSConsumerIncludeBodyTest.java | 255 +++++
.../src/main/docs/alibaba-sls-component.adoc | 37 +-
.../alibaba/sls/PutLogsDocExampleTest.java | 129 +++
.../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 +++++
.../atmosphere/websocket/atmosphere-websocket.json | 2 +-
.../agentruntime/aws-bedrock-agent-runtime.json | 2 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 7 +-
.../component/aws2/bedrock/BedrockBodyHelper.java | 52 +
.../agentruntime/BedrockAgentRuntimeEndpoint.java | 9 +-
.../agentruntime/BedrockAgentRuntimeProducer.java | 22 +-
.../aws2/bedrock/runtime/BedrockProducer.java | 12 +-
...BedrockAgentRuntimeProducerInvokeAgentTest.java | 26 +
.../BedrockAgentRuntimeProducerInvokeFlowTest.java | 24 +
.../BedrockAgentRuntimeProducerRetrieveTest.java | 46 +
.../component/azure/cosmosdb/azure-cosmosdb.json | 4 +-
.../src/main/docs/azure-cosmosdb-component.adoc | 31 +-
.../CosmosDbConfigurationOptionsProxy.java | 102 +-
.../component/azure/cosmosdb/CosmosDbEndpoint.java | 31 +-
.../cosmosdb/CosmosDbProducerItemBodyTest.java | 278 ++++++
.../component/azure/eventgrid/azure-eventgrid.json | 2 +-
.../src/main/docs/azure-eventgrid-component.adoc | 16 +
.../azure/eventgrid/EventGridEndpoint.java | 14 +-
.../azure/eventgrid/EventGridProducer.java | 87 +-
.../azure/eventgrid/EventGridProducerTest.java | 294 ++++++
.../camel-azure/camel-azure-functions/pom.xml | 5 +
.../functions/FunctionsComponentConfigurer.java | 6 +
.../functions/FunctionsEndpointConfigurer.java | 6 +
.../functions/FunctionsEndpointUriFactory.java | 3 +-
.../component/azure/functions/azure-functions.json | 50 +-
.../src/main/docs/azure-functions-component.adoc | 17 +
.../azure/functions/FunctionsConfiguration.java | 14 +
.../azure/functions/FunctionsEndpoint.java | 24 +-
.../azure/functions/FunctionsProducer.java | 43 +-
.../client/FunctionsInvocationClient.java | 36 +-
.../functions/FunctionsProducerInvokeTest.java | 316 ++++++
.../component/azure/key/vault/azure-key-vault.json | 4 +-
.../src/main/docs/azure-key-vault-component.adoc | 8 +-
.../azure/key/vault/KeyVaultEndpoint.java | 23 +-
.../azure/key/vault/KeyVaultProducer.java | 75 +-
.../azure/key/vault/KeyVaultProducerTest.java | 310 ++++++
.../apache/camel/component/camunda/camunda.json | 4 +-
.../src/main/docs/camunda-component.adoc | 41 +-
.../camel/component/camunda/CamundaEndpoint.java | 14 +-
.../camunda/model/AbstractCamundaResponse.java | 4 -
.../component/camunda/model/DeploymentRequest.java | 2 -
.../camel/component/camunda/model/JobRequest.java | 8 +-
.../component/camunda/model/MessageRequest.java | 4 -
.../component/camunda/model/MessageResponse.java | 3 -
.../camunda/model/ProcessDeploymentResponse.java | 4 -
.../component/camunda/model/ProcessRequest.java | 5 -
.../component/camunda/model/ProcessResponse.java | 5 -
.../camunda/processor/AbstractBaseProcessor.java | 31 +
.../camunda/processor/DeploymentProcessor.java | 1 +
.../component/camunda/processor/JobProcessor.java | 29 +-
.../camunda/processor/MessageProcessor.java | 19 +-
.../camunda/processor/ProcessProcessor.java | 31 +-
.../component/camunda/CamundaProducerTest.java | 301 ++++++
.../component/cassandra/CassandraProducer.java | 3 -
components/camel-chaos/pom.xml | 6 +
components/camel-chaos/src/main/docs/chaos.adoc | 35 +-
.../apache/camel/component/chaos/ChaosFaults.java | 58 +-
.../camel/component/chaos/ChaosPatterns.java | 27 +
.../camel/component/chaos/ChaosPollStrategy.java | 3 +-
.../apache/camel/component/chaos/ChaosRule.java | 9 +-
.../camel/component/chaos/ChaosRuleParser.java | 13 +-
.../camel/component/chaos/ChaosSendHook.java | 3 +-
.../camel/component/chaos/ChaosHttpFaultTest.java | 15 +-
.../component/chaos/ChaosNettyHttpFaultTest.java | 235 +++++
.../camel/component/chaos/ChaosRuleParserTest.java | 8 +-
.../camel/component/chaos/TestHttpComponent.java | 21 +-
.../src/main/docs/clickhouse-component.adoc | 1 +
.../component/clickhouse/ClickHouseProducer.java | 8 +-
.../clickhouse/ClickHouseProducerTest.java | 20 +-
.../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 +
.../component/google/bigquery/google-bigquery.json | 2 +-
.../google/bigquery/sql/google-bigquery-sql.json | 2 +-
.../src/main/docs/google-bigquery-component.adoc | 4 +
.../main/docs/google-bigquery-sql-component.adoc | 1 +
.../google/bigquery/GoogleBigQueryComponent.java | 4 +
.../google/bigquery/GoogleBigQueryEndpoint.java | 7 +-
.../google/bigquery/GoogleBigQueryProducer.java | 80 +-
.../bigquery/sql/GoogleBigQuerySQLComponent.java | 4 +
.../bigquery/sql/GoogleBigQuerySQLEndpoint.java | 8 +-
.../bigquery/sql/GoogleBigQuerySQLProducer.java | 7 +-
...ogleBigQueryComponentConnectionFactoryTest.java | 110 ++
.../unit/GoogleBigQueryProducerBodyTypeTest.java | 105 +-
.../GoogleBigQuerySQLProducerStatementTest.java | 61 ++
.../camel/component/google/drive/google-drive.json | 9 +-
.../src/main/docs/google-drive-component.adoc | 69 ++
.../google/drive/GoogleDriveConfiguration.java | 2 +-
.../google/drive/GoogleDriveConsumer.java | 22 +-
.../google/drive/GoogleDriveEndpoint.java | 25 +-
.../google/drive/GoogleDriveProducer.java | 7 +-
.../google/drive/GoogleDriveRequestHelper.java | 54 +
.../drive/internal/GoogleDriveConstants.java | 8 +-
.../component/google/drive/FileConverterIT.java | 13 +-
.../google/drive/GoogleDriveApiMethodsTest.java | 48 +
.../google/drive/GoogleDriveMediaContentTest.java | 229 +++++
.../camel-google/camel-google-functions/pom.xml | 5 +
.../google/functions/google-functions.json | 4 +-
.../src/main/docs/google-functions-component.adoc | 12 +
.../functions/GoogleCloudFunctionsEndpoint.java | 23 +-
.../functions/GoogleCloudFunctionsProducer.java | 67 +-
.../unit/GoogleCloudFunctionsCallFunctionTest.java | 275 +++++
.../unit/GoogleCloudFunctionsComponentTest.java | 4 +-
components/camel-google/camel-google-mail/pom.xml | 3 +
.../GmailUsersMessagesEndpointConfiguration.java | 4 +-
.../mail/internal/GmailUsersMessagesApiMethod.java | 4 -
.../camel/component/google/mail/google-mail.json | 6 +-
.../google/mail/GoogleMailConfiguration.java | 2 +-
.../google/mail/GmailUsersMessagesIT.java | 3 -
.../google/mail/GoogleMailApiMethodsTest.java | 114 +++
.../secret/manager/google-secret-manager.json | 4 +-
.../main/docs/google-secret-manager-component.adoc | 40 +-
.../manager/GoogleSecretManagerEndpoint.java | 20 +-
.../manager/GoogleSecretManagerProducer.java | 27 +-
.../unit/GoogleSecretManagerCreateSecretTest.java | 168 ++++
.../camel-google/camel-google-sheets/pom.xml | 3 +
.../SheetsSpreadsheetsEndpointConfiguration.java | 2 +-
.../internal/SheetsSpreadsheetsApiMethod.java | 14 +-
.../component/google/sheets/google-sheets.json | 8 +-
.../src/main/docs/google-sheets-component.adoc | 9 +
.../google/sheets/GoogleSheetsConfiguration.java | 2 +-
.../google/sheets/GoogleSheetsEndpoint.java | 4 +-
.../google/sheets/GoogleSheetsApiMethodsTest.java | 114 +++
.../GoogleSheetsConsumerSplitResultTest.java | 37 +
.../google/texttospeech/google-text-to-speech.json | 6 +-
.../main/docs/google-text-to-speech-component.adoc | 32 +-
.../GoogleCloudTextToSpeechConfiguration.java | 13 +-
.../GoogleCloudTextToSpeechEndpoint.java | 16 +-
.../GoogleCloudTextToSpeechProducer.java | 48 +-
.../unit/GoogleCloudTextToSpeechProducerTest.java | 210 ++++
.../component/google/vertexai/google-vertexai.json | 16 +-
.../src/main/docs/google-vertexai-component.adoc | 74 +-
.../google/vertexai/GoogleVertexAIConstants.java | 33 +-
.../google/vertexai/GoogleVertexAIEndpoint.java | 34 +-
.../google/vertexai/GoogleVertexAIProducer.java | 210 +++-
.../vertexai/GoogleVertexAIProducerBodyTest.java | 605 +++++++++++
.../GoogleVertexAIProducerOptionsTest.java | 36 +
.../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/http/common/DefaultHttpBinding.java | 55 +-
.../org/apache/camel/http/common/HttpBinding.java | 3 +-
.../camel/http/common/HttpCommonEndpoint.java | 9 +-
.../org/apache/camel/http/common/HttpMessage.java | 4 +
.../http/common/DefaultHttpBindingGzipTest.java | 122 +++
.../component/huaweicloud/dms/hwcloud-dms.json | 2 +-
.../src/main/docs/hwcloud-dms-component.adoc | 6 +-
.../component/huaweicloud/dms/DMSEndpoint.java | 16 +-
.../component/huaweicloud/dms/DMSProducer.java | 122 ++-
.../huaweicloud/dms/CreateInstanceKafka1Test.java | 2 +-
.../huaweicloud/dms/CreateInstanceKafka2Test.java | 2 +-
.../dms/CreateInstanceMissingStorageSpaceTest.java | 2 +-
.../huaweicloud/dms/CreateInstanceRmq1Test.java | 2 +-
.../huaweicloud/dms/CreateInstanceRmq2Test.java | 2 +-
.../huaweicloud/dms/InstanceRequestBodyTest.java | 359 +++++++
.../org/apache/camel/hwcloud-functiongraph.json | 4 +-
.../main/docs/hwcloud-functiongraph-component.adoc | 15 +
.../org/apache/camel/FunctionGraphEndpoint.java | 20 +-
.../org/apache/camel/FunctionGraphProducer.java | 72 +-
.../java/org/apache/camel/FunctionGraphUtils.java | 38 +-
.../org/apache/camel/InvokeFunctionBodyTest.java | 234 +++++
.../camel-huawei/camel-huaweicloud-iam/pom.xml | 5 -
.../component/huaweicloud/iam/hwcloud-iam.json | 4 +-
.../src/main/docs/hwcloud-iam-component.adoc | 31 +-
.../component/huaweicloud/iam/IAMEndpoint.java | 18 +-
.../component/huaweicloud/iam/IAMProducer.java | 141 ++-
.../component/huaweicloud/iam/GetUserTest.java | 2 +-
.../huaweicloud/iam/IAMProducerJsonTest.java | 371 +++++++
.../component/huaweicloud/iam/ListUsersTest.java | 2 +-
.../huaweicloud/iam/UpdateGroupJsonTest.java | 2 +-
.../component/huaweicloud/iam/UpdateGroupTest.java | 2 +-
.../component/huaweicloud/obs/OBSProducer.java | 11 +-
.../obs/PutObjectMandatoryNamesTest.java | 153 +++
.../component/huaweicloud/smn/hwcloud-smn.json | 4 +-
.../src/main/docs/hwcloud-smn-component.adoc | 13 +-
.../smn/SimpleNotificationEndpoint.java | 18 +-
.../smn/SimpleNotificationProducer.java | 70 +-
.../huaweicloud/smn/constants/SmnProperties.java | 10 +
.../huaweicloud/smn/PublishMessageBodyTest.java | 260 +++++
.../smn/PublishTemplatedMessageFunctionalTest.java | 4 +-
.../smn/PublishTemplatedMessageTest.java | 4 +-
...tedMessageWithCustomEndpointFunctionalTest.java | 4 +-
...lishTemplatedMessageWithCustomEndpointTest.java | 4 +-
.../smn/PublishTextMessageFunctionalTest.java | 4 +-
.../huaweicloud/smn/PublishTextMessageTest.java | 6 +-
...extMessageWithCustomEndpointFunctionalTest.java | 4 +-
.../PublishTextMessageWithCustomEndpointTest.java | 6 +-
.../smn/constants/SmnPropertiesTest.java | 1 +
.../camel-ibm/camel-ibm-secrets-manager/pom.xml | 6 +
.../ibm/secrets/manager/ibm-secrets-manager.json | 4 +-
.../main/docs/ibm-secrets-manager-component.adoc | 70 +-
.../secrets/manager/IBMSecretsManagerEndpoint.java | 27 +-
.../secrets/manager/IBMSecretsManagerProducer.java | 118 ++-
.../manager/IBMSecretsManagerProducerBodyTest.java | 504 ++++++++++
.../camel-ibm/camel-ibm-watson-discovery/pom.xml | 6 +
.../WatsonDiscoveryProducerQueryTest.java | 148 +++
.../camel-ibm/camel-ibm-watson-language/pom.xml | 6 +
.../camel-ibm-watson-speech-to-text/pom.xml | 6 +
.../docs/ibm-watson-speech-to-text-component.adoc | 7 +
.../ibm/watson/stt/WatsonSpeechToTextProducer.java | 40 +-
.../stt/WatsonSpeechToTextAudioStreamTest.java | 313 ++++++
.../camel-ibm-watson-text-to-speech/pom.xml | 6 +
.../component/ibm/watsonx/ai/ibm-watsonx-ai.json | 2 +-
.../src/main/docs/ibm-watsonx-ai-component.adoc | 13 +
.../ibm/watsonx/ai/WatsonxAiEndpoint.java | 21 +-
.../ai/handler/AbstractWatsonxAiHandler.java | 55 +-
.../ibm/watsonx/ai/WatsonxAiMessageBodyTest.java | 524 ++++++++++
.../camel-ibm/camel-ibm-watsonx-data/pom.xml | 6 +
.../ibm/watsonx/data/ibm-watsonx-data.json | 2 +-
.../src/main/docs/ibm-watsonx-data-component.adoc | 63 +-
.../ibm/watsonx/data/WatsonxDataEndpoint.java | 9 +-
.../ibm/watsonx/data/WatsonxDataProducer.java | 50 +-
.../ibm/watsonx/data/WatsonxDataProducerTest.java | 255 +++++
components/camel-ibm/pom.xml | 16 +
.../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 +
.../org/apache/camel/component/jetty12/jetty.json | 2 +-
.../HttpChunkedNonStreamBodyAndFormStreamTest.java | 86 ++
.../component/jetty/HttpGzipNonStreamBodyTest.java | 66 ++
.../jetty/JettyMapHttpMessageBodyFalseTest.java | 52 +
.../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 +++
.../camel-jms/src/main/docs/jms-component.adoc | 8 +
.../org/apache/camel/component/jms/JmsBinding.java | 23 +-
.../camel/component/jms/JmsUnmappableBodyTest.java | 152 +++
.../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 +-
.../src/main/docs/netty-http-component.adoc | 11 +
.../netty/http/HttpClientInitializerFactory.java | 2 +-
.../netty/http/HttpServerInitializerFactory.java | 9 +-
.../component/netty/http/NettyHttpComponent.java | 5 +-
.../component/netty/http/NettyHttpEndpoint.java | 17 +-
.../component/netty/http/NettyHttpHelper.java | 2 +-
.../http/handlers/HttpServerChannelHandler.java | 31 +-
.../netty/http/ManagedNettyEndpointTest.java | 5 +-
.../NettyHttpEndpointDifferentOptionsTest.java | 85 ++
.../http/NettyHttpResponseCannotBeBuiltTest.java | 96 ++
...NettyHttpSSLServerHostnameVerificationTest.java | 132 +++
.../org/apache/camel/component/netty/netty.json | 4 +-
.../camel/component/netty/NettyConfiguration.java | 11 +-
.../camel/component/netty/NettyPayloadHelper.java | 99 +-
.../handlers/ServerResponseFutureListener.java | 9 +
.../netty/NettyReplyWriteFailureTest.java | 79 ++
...TransferExchangeAllowSerializedHeadersTest.java | 135 +++
...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 ++
.../src/main/docs/platform-http-vertx.adoc | 7 +
.../http/vertx/VertxPlatformHttpSupport.java | 15 +-
.../VertxPlatformHttpSingleValueResponseTest.java | 142 +++
.../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 +-
.../apache/camel/component/servlet/servlet.json | 2 +-
...rvletChunkedNonStreamBodyAndFormStreamTest.java | 110 ++
.../servlet/ServletGzipNonStreamBodyTest.java | 121 +++
.../ServletMapHttpMessageBodyFalseTest.java | 65 ++
.../camel-sjms/src/main/docs/sjms-component.adoc | 3 +-
.../camel/component/sjms/jms/JmsBinding.java | 20 +-
.../consumer/InOutConsumerReplyFailureTest.java | 35 +
.../sjms/producer/UnmappableBodyTest.java | 97 ++
.../camel-sjms2/src/main/docs/sjms2-component.adoc | 3 +-
.../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 ++
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../decorators/AbstractSpanDecorator.java | 21 +-
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 +-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../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 ++
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../tracing/decorators/AbstractSpanDecorator.java | 21 +-
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 +-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../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/vertx/vertx.json | 4 +-
.../camel-vertx/src/main/docs/vertx-component.adoc | 3 +-
.../camel/component/vertx/VertxEndpoint.java | 10 +-
.../camel/component/vertx/VertxProducer.java | 35 +-
.../camel/component/vertx/VertxNullBodyTest.java | 140 +++
.../vertx/VertxRequestReplyFailureTest.java | 13 -
.../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 +-
.../zendesk/AbstractZendeskTestSupport.java | 8 +-
.../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 +-
.../org/apache/camel/support/PatternHelper.java | 26 +-
...DefaultThreadPoolFactoryVirtualThreadsTest.java | 127 +++
.../apache/camel/support/PatternHelperTest.java | 91 ++
.../java/org/apache/camel/util/SecurityUtils.java | 3 +
.../util/concurrent/BoundedExecutorService.java | 63 +-
.../concurrent/BoundedExecutorServiceTest.java | 261 +++++
design/chaos.adoc | 6 +-
.../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 | 1049 ++++++++++++++++++++
.../modules/ROOT/pages/threading-model.adoc | 13 +-
.../modules/ROOT/pages/virtual-threads.adoc | 5 +-
.../dsl/AzureFunctionsComponentBuilderFactory.java | 21 +
.../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 | 27 +
.../builder/endpoint/StaticEndpointBuilders.java | 60 +-
.../AtmosphereWebsocketEndpointBuilderFactory.java | 14 +-
.../DigitalSignatureEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/DuckDbEndpointBuilderFactory.java | 46 +-
.../dsl/FunctionsEndpointBuilderFactory.java | 36 +
...gleCloudTextToSpeechEndpointBuilderFactory.java | 4 +-
.../dsl/GoogleDriveEndpointBuilderFactory.java | 51 +-
.../dsl/GoogleMailEndpointBuilderFactory.java | 12 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 10 +-
.../dsl/GoogleVertexAIEndpointBuilderFactory.java | 27 +-
.../HazelcastPNCounterEndpointBuilderFactory.java | 37 +
.../dsl/InfluxDbEndpointBuilderFactory.java | 3 +-
.../dsl/JGroupsRaftEndpointBuilderFactory.java | 279 ++++++
.../dsl/JettyHttp12EndpointBuilderFactory.java | 14 +-
.../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/MNSEndpointBuilderFactory.java | 9 +-
.../endpoint/dsl/Neo4jEndpointBuilderFactory.java | 43 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 48 +-
.../dsl/NettyHttpEndpointBuilderFactory.java | 48 +-
.../endpoint/dsl/ODataEndpointBuilderFactory.java | 2 +
.../endpoint/dsl/OSSEndpointBuilderFactory.java | 40 +
.../dsl/OpenTelemetryEndpointBuilderFactory.java | 4 +-
.../dsl/ServletEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/Web3jEndpointBuilderFactory.java | 24 +-
.../dsl/ZooKeeperEndpointBuilderFactory.java | 4 +
.../apache/camel/dsl/jbang/core/commands/Run.java | 9 +-
.../commands/RunMcpStdioConfigurationTest.java | 58 ++
.../camel/dsl/jbang/it/CamelDebugITCase.java | 2 -
.../apache/camel/dsl/jbang/it/DevModeITCase.java | 4 +-
.../camel/dsl/jbang/it/InfrastructureITCase.java | 5 -
.../dsl/jbang/it/InfrastructureListITCase.java | 15 +-
.../apache/camel/dsl/jbang/it/JolokiaITCase.java | 2 -
.../apache/camel/dsl/jbang/it/OpenApiITCase.java | 12 +-
.../camel/dsl/jbang/it/RunCommandITCase.java | 18 +-
.../camel/dsl/jbang/it/RunCommandOnMqttITCase.java | 9 -
.../it/{CamelDebugITCase.java => StubITCase.java} | 17 +-
.../dsl/jbang/it/support/JBangTestSupport.java | 16 +-
.../commands/tui/AiCliCommandExecutorTest.java | 4 +
.../jbang/core/commands/tui/BorderRenderTest.java | 3 +
.../core/commands/tui/MonitorStartupTest.java | 12 +-
.../core/commands/tui/ShellPanelLifecycleTest.java | 8 +
dsl/camel-jbang/camel-launcher/pom.xml | 23 +
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 12 +-
parent/pom.xml | 20 +-
pom.xml | 2 +-
.../infra/cli/services/CliLocalProcessService.java | 15 +-
.../camel/test/infra/cli/services/CliService.java | 8 +
.../test/infra/cli/services/CliServiceFactory.java | 10 +
1072 files changed, 44181 insertions(+), 4239 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-alibaba/camel-alibaba-eventbridge/src/test/java/org/apache/camel/component/alibaba/eventbridge/PutEventsBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-fc/src/test/java/org/apache/camel/component/alibaba/fc/InvokeFunctionPayloadTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-kms/src/test/java/org/apache/camel/component/alibaba/kms/EncryptPlaintextTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSConsumerBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSProducerBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSProducerResponseHeadersTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSReceiveMessageOperationTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-oss/src/test/java/org/apache/camel/component/alibaba/oss/OSSConsumerIncludeBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-sls/src/test/java/org/apache/camel/component/alibaba/sls/PutLogsDocExampleTest.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-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/BedrockBodyHelper.java
create mode 100644
components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/CosmosDbProducerItemBodyTest.java
create mode 100644
components/camel-azure/camel-azure-eventgrid/src/test/java/org/apache/camel/component/azure/eventgrid/EventGridProducerTest.java
create mode 100644
components/camel-azure/camel-azure-functions/src/test/java/org/apache/camel/component/azure/functions/FunctionsProducerInvokeTest.java
create mode 100644
components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/KeyVaultProducerTest.java
create mode 100644
components/camel-camunda/src/test/java/org/apache/camel/component/camunda/CamundaProducerTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosNettyHttpFaultTest.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-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/unit/GoogleBigQueryComponentConnectionFactoryTest.java
create mode 100644
components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/unit/sql/GoogleBigQuerySQLProducerStatementTest.java
create mode 100644
components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveRequestHelper.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveMediaContentTest.java
create mode 100644
components/camel-google/camel-google-functions/src/test/java/org/apache/camel/component/google/functions/unit/GoogleCloudFunctionsCallFunctionTest.java
create mode 100644
components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/GoogleMailApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-secret-manager/src/test/java/org/apache/camel/component/google/secret/manager/unit/GoogleSecretManagerCreateSecretTest.java
create mode 100644
components/camel-google/camel-google-sheets/src/test/java/org/apache/camel/component/google/sheets/GoogleSheetsApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-text-to-speech/src/test/java/org/apache/camel/component/google/texttospeech/unit/GoogleCloudTextToSpeechProducerTest.java
create mode 100644
components/camel-google/camel-google-vertexai/src/test/java/org/apache/camel/component/google/vertexai/GoogleVertexAIProducerBodyTest.java
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-http-common/src/test/java/org/apache/camel/http/common/DefaultHttpBindingGzipTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-dms/src/test/java/org/apache/camel/component/huaweicloud/dms/InstanceRequestBodyTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-functiongraph/src/test/java/org/apache/camel/InvokeFunctionBodyTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-iam/src/test/java/org/apache/camel/component/huaweicloud/iam/IAMProducerJsonTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/PutObjectMandatoryNamesTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishMessageBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-secrets-manager/src/test/java/org/apache/camel/component/ibm/secrets/manager/IBMSecretsManagerProducerBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-watson-discovery/src/test/java/org/apache/camel/component/ibm/watson/discovery/WatsonDiscoveryProducerQueryTest.java
create mode 100644
components/camel-ibm/camel-ibm-watson-speech-to-text/src/test/java/org/apache/camel/component/ibm/watson/stt/WatsonSpeechToTextAudioStreamTest.java
create mode 100644
components/camel-ibm/camel-ibm-watsonx-ai/src/test/java/org/apache/camel/component/ibm/watsonx/ai/WatsonxAiMessageBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-watsonx-data/src/test/java/org/apache/camel/component/ibm/watsonx/data/WatsonxDataProducerTest.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-jetty/src/test/java/org/apache/camel/component/jetty/HttpChunkedNonStreamBodyAndFormStreamTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpGzipNonStreamBodyTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyMapHttpMessageBodyFalseTest.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-jms/src/test/java/org/apache/camel/component/jms/JmsUnmappableBodyTest.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-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpResponseCannotBeBuiltTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpSSLServerHostnameVerificationTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyReplyWriteFailureTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTransferExchangeAllowSerializedHeadersTest.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-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpSingleValueResponseTest.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-servlet/src/test/java/org/apache/camel/component/servlet/ServletChunkedNonStreamBodyAndFormStreamTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletGzipNonStreamBodyTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletMapHttpMessageBodyFalseTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/UnmappableBodyTest.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-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxNullBodyTest.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
copy
components/camel-dhis2/camel-dhis2-component/src/main/java/org/apache/camel/component/dhis2/Dhis2Consumer.java
=>
dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/InfrastructureListITCase.java
(66%)
copy
dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/{CamelDebugITCase.java
=> StubITCase.java} (65%)
