This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch fix/CAMEL-26487
in repository https://gitbox.apache.org/repos/asf/camel.git
discard 7c3bd9e52a2c CAMEL-26487: camel-netty-http - include the endpoint
options in the endpoint URI
add 25dec672fb91 chore(deps): Bump com.prowidesoftware:pw-iso20022
add 1696ae8ecf7b CAMEL-25895: docs - upgrade-guide notes for the Swift
header rename on the 4.18.6 and 4.22.3 lines (#28850)
add 50cf59774b53 CAMEL-26471: camel-util - StopWatch.taken: convert to
millis without a Duration (#28815)
add 20e4ff7c2638 CAMEL-26457: camel-disruptor - disruptor-vm queue shared
by several CamelContexts could get a second ring buffer (#28813)
add 48ea92c4092b CAMEL-26453: camel-dynamic-router - a route that sends to
a channel can be added again after it was removed (#28810)
add b2eb665ea77f CAMEL-26450: camel-telemetry - end the span of an
asynchronous step before the next step starts (#28806)
add 92c353446b56 CAMEL-26449: camel-core - DefaultShutdownStrategy: a
route stop that times out must not force or cut short the CamelContext stop
(#28805)
add 652f8c8b2b9f CAMEL-26486: camel-cassandraql - Fix flaky
CassandraKeyValueRepositoryIT
add f94c88c34bf4 CAMEL-26480: camel-jbang - follow-up improvements for
deterministic file ordering
add 8a8060b34f3b chore(deps): Bump huaweicloud-sdk-version from 3.1.221 to
3.1.222
add d1c83b567a0f chore(deps): Bump com.microsoft.onnxruntime:onnxruntime
add f4ef698232a4 chore(deps): Bump logback-version from 1.6.5 to 1.6.6
add 3ad52131a331 chore(deps): Bump com.github.ben-manes.caffeine:caffeine
add 7c80470b6c7e chore(deps): Bump mongo-java-driver-version from 5.13.0
to 5.14.0
add 6e68019c2c5a CAMEL-26481: camel-syslog - handle fragmented length
fields in Rfc5425FrameDecoder (#28846)
add d729e33c5c38 CAMEL-26456: camel-chaos - route lifecycle faults (stall
and lifecycle action=suspend|stop|remove) (#28812)
add 8f5c5ad9ff4f chore(deps): Bump dev.openfeature.contrib.providers:flagd
add c2495ef423f4 CAMEL-26482: camel-jbang - AI tools: a to: that copies
the files a file consumer moves, a placeholder left unused, and the place of an
errorHandler (#28847)
add 30afcab269af CAMEL-26483: camel-jbang - AI tools: a field of the body
a pollEnrich replaced, a variable for ${property.x}, an exception class with no
key, and no trigger note for noErrorHandler (#28848)
add 6267e9502f2a CAMEL-26489: Fix flaky ThrottlingGroupingTest
add b0501342dcdf CAMEL-26394: Fix flakiness in
SpringQuartzPersistentStoreRestartAppChangeOptionsTest
add 25ce93346f73 chore(deps): Bump com.ibm.mq:com.ibm.mq.jakarta.client
from 10.0.0.5 to 10.0.1.0 (#28852)
add 98eacfb58be3 CAMEL-26237: camel-ehcache: fix shared CacheManager, null
body handling, consumer events, and type defaults (#28822)
add ccbbcde2ea47 CAMEL-26315: Fix
TransientResumeStrategy.createSimpleCache().forEach() inverted boolean and
ConcurrentModificationException; fix KafkaResumeAdapter.resume() return value
(#28521)
add 41b262714416 CAMEL-26484: camel-jbang - AI tools: a JsonPath or SpEL
filter in Simple, a jsonpath text that is not a path, {id} for a path parameter
and json as a language are caught at write time (#28849)
add e373d74b8ccf CAMEL-26445: camel-core - RedeliveryErrorHandler: an
AsyncProcessor that throws completes the exchange instead of hanging when the
error handler has no redelivery (#28808)
add e45558b86144 CAMEL-26488: camel-mina - close the synchronous producer
session when a request times out (#28865)
add 9c2f59172db1 chore(deps): Bump
io.opentelemetry.instrumentation:opentelemetry-log4j-appender-2.17 from
2.33.0-alpha to 2.33.1-alpha (#28875)
add 024c8ec9251f chore: package-native validation - build
camel-yaml-dsl-validator from source (#28886)
add 4aec9c429a23 chore(deps): Bump com.google.errorprone:error_prone_core
add 754ce2cb1da3 chore(deps): Bump org.apache.xmlgraphics:fop from 2.11 to
2.12
add 381293125d0f chore(deps): Bump
org.springframework.vault:spring-vault-core
add 6c07f5118645 chore(deps): Bump google-cloud-functions-version from
2.87.0 to 2.88.0
add f1a7e78fbff1 chore(deps): Bump quarkus-mcp-server-version from 2.0.3
to 2.0.4
add 9a213fde6154 chore(deps): Bump djl-version from 0.39.0 to 0.40.0
add f97346b80f2c chore(deps): Bump org.duckdb:duckdb_jdbc from 1.5.6.0 to
2.0.0.0 (#28881)
add 030d45983834 CAMEL-26161: camel-zendesk - the documented syntax
zendesk:methodName fails endpoint creation (#28936)
add af6bef4113d8 CAMEL-26493: camel-jbang - AI tools: a Citrus test is
checked as YAML, not as a route, and the examples show their Citrus tests
(#28872)
add c21135a79196 CAMEL-26495: camel-jbang - camel run and camel_run do not
start a Citrus test, and say to use camel test run (#28884)
add 9af87a8bedb9 CAMEL-25973: camel-language - binary=true with a file: or
classpath: script returns the content as a stream (#28889)
add 3af4458ddef7 CAMEL-26062: camel-smooks - SAXSource, remote file, File
and Path bodies are read, exports come in a fixed order (#28890)
add 42b0c1c1e151 CAMEL-26100: camel-aws2-athena - result headers are not
taken as the input of a later operation (#28891)
add d56ad66487bc CAMEL-26069: camel-aws-bedrock - send the body as bytes,
and fail the streaming of image and embedding models (#28892)
add ac961f81d7cb CAMEL-26117: camel-debezium - the row flattened by
ExtractNewRecordState is the body, and mongodb updates expose their
updateDescription (#28893)
add 1452a4594383 CAMEL-26071: camel-aws-bedrock -
aws-bedrock-agent-runtime: invokeFlow converts the body, and the operation
header works on an endpoint of another operation (#28894)
add 0e2a286dc6de CAMEL-26118: camel-flowable - a producer created before
its channel is deployed sends once the channel is deployed, and fails with a
clear error until then (#28895)
add 3eb4c51cb6eb CAMEL-26120: camel-bonita - startCase sets the id of the
started case in a header, and a body that is not a Map fails with
InvalidPayloadException (#28897)
add 3464d84544f2 CAMEL-26121: camel-flink - use the component dataStream
options, and return a DataStream with the default collect (#28898)
add e6d529b9d3e3 CAMEL-26122: camel-spring-batch - skip null headers and
honour jobFromHeader=false (#28899)
add 0ec3f6909c26 CAMEL-26124: camel-jt400 - Fix program call without
outputFieldsIdx and with a List body (#28900)
add 8b900e03ccdf CAMEL-26125: camel-jcr - the insert operation keeps the
headers of the message (#28901)
add 1635587b1f90 CAMEL-26123: camel-optaplanner - one SolverManager per
endpoint, per-context consumers and sync events (#28902)
add 22806dff2f7b CAMEL-26127: camel-fop - accept a DOM or Source body and
fail clearly on no body (#28903)
add 41d9dd8ab401 CAMEL-26128: camel-flatpack - with splitRows each row
message has its own row, and a failing row fails the producer (#28906)
add ca69f7cf4424 CAMEL-26133: camel-robotframework - skip null body,
header, variable and property values (#28907)
add c0177a5a77a0 CAMEL-26132: camel-rss - Fail the exchange when the feed
cannot be cloned for a split entry (#28908)
add 6eec69b21a39 CAMEL-26134: camel-test-citrus - Validate byte[], file
and stream bodies by their content (#28909)
add 62c8f6e00fca CAMEL-26140: camel-undertow - send a number as text, fail
on a Map or object body, read a DELETE body, null body for a 204 (#28910)
add 958036619c28 CAMEL-26139: camel-servlet - attachmentMultipartBinding
only reads parts of multipart/form-data requests (#28912)
add 9aba86e0ad37 CAMEL-26141: camel-atmosphere-websocket - fix query
parameter without a value and the useStreaming description (#28913)
add c3ce839be05f CAMEL-26136: camel-netty - convert replies for the
default codec, fail on useByteBuf, ignore replies with sync=false (#28914)
add 1ec55622dbb4 CAMEL-26142: camel-spring-ws - null reply body, non-XML
reply body, and File/InputStream producer bodies (#28915)
add 7a48feff33a3 CAMEL-26145: camel-mybatis - Keep the body with InOut,
and fail an Insert, Update or Delete without a body when the statement has
parameters (#28916)
add 137d447a68b1 CAMEL-26146: camel-jooq - fail on an empty body and drop
the CONSUME operation from the catalog (#28917)
add f345ef6a17a6 CAMEL-26148: camel-sql - sql and sql-stored batch update
count and single Map body (#28918)
add c09c01f957f9 CAMEL-26149: camel-duckdb - document the query option
precedence, hint at the operation on a wrong statement kind, and accept a Path
or bytes body for copy (#28919)
add cf6980d06db0 CAMEL-26143: camel-cxf - fix byte[] reply, POJO parameter
splitting and bodies sent as empty messages (#28920)
add e6433f423187 CAMEL-26151: camel-pg-replication-slot - keep the
generated exchange id and put the LSN in a header (#28921)
add a1b1c8b719b0 CAMEL-26150: camel-clickhouse - return binary query
results as byte[] and fail List inserts with a clear message (#28922)
add fe77c8e2bc3e CAMEL-26144: camel-cxfrs - reply with an unchanged
request body and send a whole List body (#28923)
add f5475dfc57c9 CAMEL-26153: camel-hivemq - fail the exchange for a body
that does not convert to byte[] instead of publishing an empty payload (#28924)
add 3f3f25513695 CAMEL-26154: camel-iggy - send binary bodies as bytes and
give the consumer body as bytes (#28927)
add 9ef0c09fffde CAMEL-26155: camel-rocketmq - waitForSendResult=false
completes the exchange synchronously, and the headers are named CamelRocketMQ
(#28933)
add 48894fe86592 CAMEL-26160: camel-servicenow - remove dead Map branch in
AbstractServiceNowProcessor.unwrap (#28935)
add 2a57a18cad45 CAMEL-26163: camel-wordpress - convert a JSON text or Map
body to a Post or User (#28939)
add 9ee1e7cfade6 CAMEL-26164: camel-whatsapp - fix webhook query parsing
and a missing HTTP method (#28940)
add 020181ed8a63 CAMEL-26158: camel-vertx - reply with a stream as a
Buffer, and with a failure when the reply has no codec (#28941)
add 9a9c07ebd051 CAMEL-26166: camel-stripe - convert bytes and stream
bodies, read the CamelStripeOperation header, no retrieve before update (#28944)
add 4afa8ead45a3 CAMEL-26168: camel-twitter - fail a direct message with
no body, list only usable timeline types (#28946)
add a5c66632bf68 CAMEL-26129: camel-dfdl - fail clearly on a null or Map
body and give parse errors a message (#28905)
add 180eebf592c7 CAMEL-26169: camel-sap-netweaver - keep the url query
string and support special characters in the credentials (#28945)
add bdffa3751f26 CAMEL-26126: camel-stax - accept a byte[], Path or DOM
Document body (#28904)
add 696f8c88aed7 CAMEL-26156: camel-pubnub - FIRE and SETSTATE with an
empty body fail without calling PubNub, and PNMessageResult converts to String
(#28928)
add f3f949af1e94 CAMEL-26159: camel-salesforce - send a Map or POJO body
as JSON, fail raw on a body it cannot send (#28942)
add 50376680fdd7 CAMEL-26165: camel-clickup - deliver webhook events of
other kinds as GenericEvent instead of failing with 500 (#28943)
add ef973877aec6 CAMEL-26499: camel-smooks - convert a remote file to a
Smooks Source, set the execution context header on a bean route with a
correlation id (#28977)
add 20a3c9d83f8e CAMEL-26498: camel-xml-jaxp - stream caching a SAXSource
without an XMLReader parses it with the secure XMLReader (#28979)
add 496f8c8bdd1b CAMEL-26500: camel-aws-bedrock - deprecate the
invokeImageModelStreaming and invokeEmbeddingsModelStreaming operations (#28980)
add 0d1d5ab0f989 CAMEL-26152: camel-sjms - fail the message when an InOut
reply cannot be sent, and support jmsMessageType=Stream (#28925)
add df4fa21ee94e CAMEL-26502: camel-bonita - startCase accepts a JSON text
body as the contract inputs (#28982)
add 9b839f3fda97 chore: camel-debezium-mongodb - docs: CamelDebeziumBefore
is set with the pre-image capture modes (#28978)
add eab9a0ca3b62 chore: camel-rss - do not log a WARN when the feed cannot
be cloned (#28983)
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 c0d5d6ca9383 CAMEL-26487: camel-netty-http - include the endpoint
options in the endpoint URI
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 (7c3bd9e52a2c)
\
N -- N -- N refs/heads/fix/CAMEL-26487 (c0d5d6ca9383)
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 +-
.github/workflows/package-native-validation.yml | 8 +-
.../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 +-
.../catalog/components/atmosphere-websocket.json | 4 +-
.../components/aws-bedrock-agent-runtime.json | 12 +-
.../camel/catalog/components/aws-bedrock.json | 16 +-
.../camel/catalog/components/azure-eventgrid.json | 2 +-
.../camel/catalog/components/azure-functions.json | 50 +-
.../apache/camel/catalog/components/bonita.json | 7 +-
.../apache/camel/catalog/components/camunda.json | 4 +-
.../apache/camel/catalog/components/citrus.json | 2 +-
.../camel/catalog/components/clickhouse.json | 4 +-
.../apache/camel/catalog/components/clickup.json | 2 +-
.../org/apache/camel/catalog/components/cxf.json | 4 +-
.../org/apache/camel/catalog/components/cxfrs.json | 4 +-
.../camel/catalog/components/debezium-mongodb.json | 5 +-
.../apache/camel/catalog/components/duckdb.json | 6 +-
.../apache/camel/catalog/components/flatpack.json | 4 +-
.../org/apache/camel/catalog/components/flink.json | 4 +-
.../org/apache/camel/catalog/components/fop.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 +-
.../apache/camel/catalog/components/hivemq.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 +-
.../camel/catalog/components/ibm-watsonx-ai.json | 2 +-
.../org/apache/camel/catalog/components/iggy.json | 15 +-
.../org/apache/camel/catalog/components/jetty.json | 2 +-
.../org/apache/camel/catalog/components/jooq.json | 4 +-
.../org/apache/camel/catalog/components/jt400.json | 2 +-
.../camel/catalog/components/optaplanner.json | 4 +-
.../catalog/components/pg-replication-slot.json | 5 +-
.../apache/camel/catalog/components/pubnub.json | 2 +-
.../camel/catalog/components/robotframework.json | 2 +-
.../apache/camel/catalog/components/rocketmq.json | 44 +-
.../camel/catalog/components/salesforce.json | 6 +-
.../apache/camel/catalog/components/servlet.json | 2 +-
.../org/apache/camel/catalog/components/sjms.json | 2 +-
.../org/apache/camel/catalog/components/sjms2.json | 2 +-
.../camel/catalog/components/spring-batch.json | 4 +-
.../camel/catalog/components/sql-stored.json | 6 +-
.../org/apache/camel/catalog/components/sql.json | 4 +-
.../org/apache/camel/catalog/components/stax.json | 2 +-
.../apache/camel/catalog/components/stripe.json | 4 +-
.../catalog/components/twitter-directmessage.json | 2 +-
.../camel/catalog/components/twitter-timeline.json | 2 +-
.../org/apache/camel/catalog/components/vertx.json | 8 +-
.../apache/camel/catalog/components/wordpress.json | 2 +-
.../apache/camel/catalog/dev-consoles-openapi.json | 5 +
.../apache/camel/catalog/dev-consoles/chaos.json | 5 +
.../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 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 19 +-
.../camel/catalog/docs/aws-bedrock-component.adoc | 32 +-
.../camel/catalog/docs/aws2-athena-component.adoc | 15 +-
.../catalog/docs/azure-eventgrid-component.adoc | 16 +
.../catalog/docs/azure-functions-component.adoc | 17 +
.../camel/catalog/docs/bonita-component.adoc | 7 +-
.../camel/catalog/docs/camunda-component.adoc | 41 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 141 +++-
.../camel/catalog/docs/citrus-component.adoc | 10 +
.../camel/catalog/docs/clickhouse-component.adoc | 14 +-
.../camel/catalog/docs/clickup-component.adoc | 6 +
.../apache/camel/catalog/docs/cxf-component.adoc | 7 +
.../apache/camel/catalog/docs/cxfrs-component.adoc | 11 +-
.../camel/catalog/docs/debezium-db2-component.adoc | 6 +
.../catalog/docs/debezium-mongodb-component.adoc | 19 +-
.../catalog/docs/debezium-mysql-component.adoc | 6 +
.../catalog/docs/debezium-oracle-component.adoc | 6 +
.../catalog/docs/debezium-postgres-component.adoc | 6 +
.../catalog/docs/debezium-sqlserver-component.adoc | 6 +
.../camel/catalog/docs/duckdb-component.adoc | 10 +-
.../camel/catalog/docs/ehcache-component.adoc | 16 +-
.../camel/catalog/docs/flatpack-component.adoc | 12 +-
.../apache/camel/catalog/docs/flink-component.adoc | 3 +-
.../camel/catalog/docs/flowable-component.adoc | 8 +-
.../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 +-
.../camel/catalog/docs/hivemq-component.adoc | 4 +
.../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-watson-speech-to-text-component.adoc | 7 +
.../catalog/docs/ibm-watsonx-ai-component.adoc | 13 +
.../apache/camel/catalog/docs/iggy-component.adoc | 24 +-
.../apache/camel/catalog/docs/jms-component.adoc | 8 +
.../apache/camel/catalog/docs/jooq-component.adoc | 3 +
.../apache/camel/catalog/docs/jt400-component.adoc | 8 +-
.../camel/catalog/docs/language-component.adoc | 44 ++
.../camel/catalog/docs/mybatis-component.adoc | 6 +
.../apache/camel/catalog/docs/netty-component.adoc | 10 +
.../camel/catalog/docs/netty-http-component.adoc | 11 +
.../camel/catalog/docs/optaplanner-component.adoc | 12 +-
.../docs/pg-replication-slot-component.adoc | 3 +
.../camel/catalog/docs/platform-http-vertx.adoc | 7 +
.../camel/catalog/docs/pubnub-component.adoc | 3 +
.../catalog/docs/robotframework-component.adoc | 24 +-
.../camel/catalog/docs/rocketmq-component.adoc | 20 +-
.../apache/camel/catalog/docs/rss-component.adoc | 5 +
.../camel/catalog/docs/salesforce-component.adoc | 2 +-
.../camel/catalog/docs/salesforce-rest-api.adoc | 3 +
.../apache/camel/catalog/docs/sjms-component.adoc | 8 +-
.../apache/camel/catalog/docs/sjms2-component.adoc | 8 +-
.../camel/catalog/docs/smooks-component.adoc | 4 +-
.../camel/catalog/docs/spring-batch-component.adoc | 8 +-
.../camel/catalog/docs/spring-ws-component.adoc | 8 +
.../apache/camel/catalog/docs/sql-component.adoc | 4 +
.../camel/catalog/docs/sql-stored-component.adoc | 18 +
.../apache/camel/catalog/docs/stax-component.adoc | 1 +
.../camel/catalog/docs/stripe-component.adoc | 9 +-
.../docs/twitter-directmessage-component.adoc | 3 +-
.../camel/catalog/docs/undertow-component.adoc | 11 +
.../apache/camel/catalog/docs/vertx-component.adoc | 19 +-
.../camel/catalog/docs/wordpress-component.adoc | 5 +
.../camel/catalog/main/important-headers.json | 2 +-
.../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 ++++
.../atmosphere/websocket/atmosphere-websocket.json | 4 +-
.../atmosphere/websocket/WebsocketConsumer.java | 10 +-
.../atmosphere/websocket/WebsocketEndpoint.java | 3 +-
.../websocket/WebsocketQueryParameterTest.java | 63 ++
.../agentruntime/aws-bedrock-agent-runtime.json | 12 +-
.../aws2/bedrock/runtime/aws-bedrock.json | 16 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 19 +-
.../src/main/docs/aws-bedrock-component.adoc | 32 +-
.../component/aws2/bedrock/BedrockBodyHelper.java | 52 ++
.../BedrockAgentRuntimeConfiguration.java | 6 +-
.../agentruntime/BedrockAgentRuntimeConstants.java | 2 +-
.../agentruntime/BedrockAgentRuntimeEndpoint.java | 44 +-
.../agentruntime/BedrockAgentRuntimeProducer.java | 69 +-
.../aws2/bedrock/runtime/BedrockConfiguration.java | 4 +-
.../aws2/bedrock/runtime/BedrockConstants.java | 9 +-
.../aws2/bedrock/runtime/BedrockEndpoint.java | 10 +-
.../aws2/bedrock/runtime/BedrockOperations.java | 10 +
.../aws2/bedrock/runtime/BedrockProducer.java | 145 +++-
.../bedrock/runtime/stream/Ai21StreamParser.java | 86 +++
.../runtime/stream/ConverseStreamHandler.java | 16 +-
.../bedrock/runtime/stream/NovaStreamParser.java | 74 ++
.../runtime/stream/StreamParserFactory.java | 8 +-
.../BedrockAgentRuntimeEndpointTest.java | 38 +
...BedrockAgentRuntimeProducerInvokeAgentTest.java | 26 +
.../BedrockAgentRuntimeProducerInvokeFlowTest.java | 59 ++
.../BedrockAgentRuntimeProducerOperationTest.java | 146 ++++
.../BedrockAgentRuntimeProducerRetrieveTest.java | 46 ++
...BedrockInvokeTextModelUnsupportedModelTest.java | 1 +
.../runtime/BedrockProducerRequestTest.java | 431 ++++++++++++
.../runtime/stream/ConverseStreamHandlerTest.java | 43 ++
.../src/main/docs/aws2-athena-component.adoc | 15 +-
.../component/aws2/athena/Athena2Producer.java | 97 ++-
.../athena/Athena2ProducerResultHeadersTest.java | 253 +++++++
.../aws2/kinesis/KinesisConsumerPositionTest.java | 7 +-
.../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 +++++++++
components/camel-bonita/pom.xml | 4 +
.../org/apache/camel/component/bonita/bonita.json | 7 +-
.../src/main/docs/bonita-component.adoc | 7 +-
.../camel/component/bonita/BonitaConstants.java} | 16 +-
.../camel/component/bonita/BonitaEndpoint.java | 15 +-
.../bonita/producer/BonitaStartProducer.java | 45 +-
.../component/bonita/BonitaStartProducerTest.java | 212 ++++++
.../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 ++++++++
.../cassandra/CassandraKeyValueRepositoryIT.java | 195 +++---
components/camel-chaos/pom.xml | 11 +
.../org/apache/camel/dev-console/chaos.json | 5 +
components/camel-chaos/src/main/docs/chaos.adoc | 141 +++-
.../component/chaos/ChaosContextServicePlugin.java | 20 +-
.../camel/component/chaos/ChaosDevConsole.java | 3 +-
.../apache/camel/component/chaos/ChaosFaults.java | 58 +-
.../camel/component/chaos/ChaosLifecycle.java | 583 ++++++++++++++++
.../apache/camel/component/chaos/ChaosManager.java | 59 ++
.../camel/component/chaos/ChaosPatterns.java | 27 +
.../camel/component/chaos/ChaosPollStrategy.java | 3 +-
.../apache/camel/component/chaos/ChaosReport.java | 84 ++-
.../apache/camel/component/chaos/ChaosRule.java | 59 +-
.../camel/component/chaos/ChaosRuleParser.java | 144 +++-
.../camel/component/chaos/ChaosSendHook.java | 3 +-
.../camel/component/chaos/ChaosDevConsoleTest.java | 20 +
.../camel/component/chaos/ChaosHttpFaultTest.java | 15 +-
.../component/chaos/ChaosLifecycleStartupTest.java | 186 +++++
.../camel/component/chaos/ChaosLifecycleTest.java | 459 ++++++++++++
.../component/chaos/ChaosNettyHttpFaultTest.java | 235 +++++++
.../camel/component/chaos/ChaosRuleParserTest.java | 92 ++-
.../camel/component/chaos/TestHttpComponent.java | 21 +-
.../camel/component/clickhouse/clickhouse.json | 4 +-
.../src/main/docs/clickhouse-component.adoc | 14 +-
.../component/clickhouse/ClickHouseConstants.java | 4 +-
.../component/clickhouse/ClickHouseEndpoint.java | 13 +-
.../component/clickhouse/ClickHouseProducer.java | 59 +-
.../clickhouse/ClickHouseProducerTest.java | 87 ++-
.../integration/ClickHouseProducerIT.java | 42 ++
.../apache/camel/component/clickup/clickup.json | 2 +-
.../src/main/docs/clickup-component.adoc | 6 +
.../camel/component/clickup/ClickUpEndpoint.java | 9 +-
.../camel/component/clickup/model/Event.java | 15 +-
.../component/clickup/model/GenericEvent.java | 60 ++
.../component/clickup/ClickUpWebhookCallTest.java | 41 ++
.../resources/messages/events/task-created.json | 38 +
.../apache/camel/component/cxf/jaxrs/cxfrs.json | 4 +-
.../src/main/docs/cxfrs-component.adoc | 11 +-
.../camel/component/cxf/jaxrs/CxfRsEndpoint.java | 12 +-
.../component/cxf/jaxrs/DefaultCxfRsBinding.java | 40 +-
.../component/cxf/jaxrs/SimpleCxfRsBinding.java | 3 +-
.../cxf/jaxrs/CxfRsConsumerUnchangedBodyTest.java | 99 +++
.../cxf/jaxrs/DefaultCxfRsBindingTest.java | 89 +++
.../org/apache/camel/component/cxf/jaxws/cxf.json | 4 +-
.../src/main/docs/cxf-component.adoc | 7 +
.../camel/component/cxf/jaxws/CxfEndpoint.java | 37 +-
.../camel/component/cxf/jaxws/CxfProducer.java | 25 +-
.../component/cxf/jaxws/DefaultCxfBinding.java | 43 +-
.../component/cxf/jaxws/BodyTypeService.java} | 21 +-
.../component/cxf/jaxws/CxfBodyTypesTest.java | 174 +++++
.../component/debezium/DebeziumConstants.java | 5 +
.../camel/component/debezium/DebeziumEndpoint.java | 38 +-
.../component/debezium/DebeziumTypeConverter.java | 34 +-
.../component/debezium/DebeziumEndpointTest.java | 95 ++-
.../debezium/DebeziumTypeConverterTest.java | 27 +
.../src/main/docs/debezium-db2-component.adoc | 6 +
.../debezium/mongodb/debezium-mongodb.json | 5 +-
.../src/main/docs/debezium-mongodb-component.adoc | 19 +-
.../debezium/mongodb/DebeziumMongodbEndpoint.java | 28 +-
.../mongodb/DebeziumMongodbEndpointTest.java | 125 ++++
.../src/main/docs/debezium-mysql-component.adoc | 6 +
.../src/main/docs/debezium-oracle-component.adoc | 6 +
.../src/main/docs/debezium-postgres-component.adoc | 6 +
.../main/docs/debezium-sqlserver-component.adoc | 6 +
.../apache/camel/component/dfdl/DfdlEndpoint.java | 4 +-
.../camel/component/dfdl/DfdlParseException.java | 22 +
.../camel/component/dfdl/DfdlUnparseException.java | 1 +
.../camel/dataformat/dfdl/DfdlDataFormat.java | 5 +-
.../camel/component/dfdl/DfdlComponentTest.java | 40 +-
.../camel/dataformat/dfdl/DfdlDataFormatTest.java | 57 +-
.../component/disruptor/DisruptorComponent.java | 76 +-
.../component/disruptor/DisruptorEndpoint.java | 16 +-
.../component/disruptor/DisruptorReference.java | 45 ++
.../disruptor/vm/DisruptorVmComponent.java | 40 +-
.../DisruptorVmSharedQueueReferenceTest.java | 438 ++++++++++++
.../vm/DisruptorVmComponentStartCounterTest.java | 53 ++
.../org/apache/camel/component/duckdb/duckdb.json | 6 +-
.../src/main/docs/duckdb-component.adoc | 10 +-
.../camel/component/duckdb/DuckDbConstants.java | 4 +-
.../camel/component/duckdb/DuckDbEndpoint.java | 8 +-
.../camel/component/duckdb/DuckDbProducer.java | 31 +-
.../camel/component/duckdb/DuckDbProducerTest.java | 98 +++
.../routing/DynamicRouterComponent.java | 90 ++-
.../routing/DynamicRouterEndpoint.java | 46 +-
.../routing/DynamicRouterProcessor.java | 18 +
.../routing/DynamicRouterProducer.java | 27 +-
.../routing/DynamicRouterComponentTest.java | 55 +-
.../routing/DynamicRouterProducerTest.java | 20 +
.../routing/DynamicRouterRemoveRouteTest.java | 275 ++++++++
.../src/main/docs/ehcache-component.adoc | 16 +-
.../camel/component/ehcache/EhcacheComponent.java | 5 +-
.../camel/component/ehcache/EhcacheConsumer.java | 2 +-
.../camel/component/ehcache/EhcacheManager.java | 95 ++-
.../camel/component/ehcache/EhcacheProducer.java | 4 +-
.../ehcache/EhcacheCacheConfigurationTest.java | 4 +-
.../component/ehcache/EhcacheDefaultsTest.java | 207 ++++++
.../component/ehcache/EhcacheRemoveRouteTest.java | 77 ++-
.../apache/camel/component/flatpack/flatpack.json | 4 +-
.../src/main/docs/flatpack-component.adoc | 12 +-
.../camel/component/flatpack/DataSetRow.java | 343 +++++++++
.../component/flatpack/FlatpackConverter.java | 4 +
.../camel/component/flatpack/FlatpackEndpoint.java | 32 +-
.../camel/component/flatpack/FlatpackProducer.java | 6 +-
.../component/flatpack/FlatpackSplitRowsTest.java | 201 ++++++
.../org/apache/camel/component/flink/flink.json | 4 +-
.../camel-flink/src/main/docs/flink-component.adoc | 3 +-
.../component/flink/DataStreamFlinkProducer.java | 6 +-
.../camel/component/flink/FlinkEndpoint.java | 27 +-
.../DataStreamComponentOptionsAndCollectTest.java | 87 +++
.../src/main/docs/flowable-component.adoc | 8 +-
.../camel/component/flowable/FlowableEndpoint.java | 8 +
.../camel/component/flowable/FlowableProducer.java | 26 +-
.../FlowableProducerChannelNotDeployedTest.java | 85 +++
.../resources/channel/userRouteChannel.channel | 10 +
.../org/apache/camel/component/fop/fop.json | 2 +-
.../apache/camel/component/fop/FopEndpoint.java | 7 +-
.../apache/camel/component/fop/FopProducer.java | 18 +-
.../apache/camel/component/fop/FopBodyTest.java | 93 +++
.../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/hivemq/hivemq.json | 2 +-
.../src/main/docs/hivemq-component.adoc | 4 +
.../camel/component/hivemq/HiveMQEndpoint.java | 3 +-
.../camel/component/hivemq/HiveMQProducer.java | 27 +-
.../component/hivemq/HiveMQProducerBodyTest.java | 187 +++++
.../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 +
.../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 ++++++++++++++
components/camel-ibm/pom.xml | 16 +
.../org/apache/camel/component/iggy/iggy.json | 15 +-
.../camel-iggy/src/main/docs/iggy-component.adoc | 24 +-
.../apache/camel/component/iggy/IggyConstants.java | 18 +
.../apache/camel/component/iggy/IggyEndpoint.java | 16 +-
.../camel/component/iggy/IggyFetchRecords.java | 3 +-
.../apache/camel/component/iggy/IggyProducer.java | 45 +-
.../camel/component/iggy/IggyConsumerIT.java | 2 +-
.../camel/component/iggy/IggyMessageBodyTest.java | 244 +++++++
.../apache/camel/component/iggy/IggyTestBase.java | 5 +-
.../apache/camel/component/jcr/JcrProducer.java | 2 +-
.../camel/component/jcr/JcrProducerTest.java | 24 +
.../org/apache/camel/component/jetty12/jetty.json | 2 +-
.../HttpChunkedNonStreamBodyAndFormStreamTest.java | 86 +++
.../component/jetty/HttpGzipNonStreamBodyTest.java | 66 ++
.../jetty/JettyMapHttpMessageBodyFalseTest.java | 52 ++
.../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/jooq/jooq.json | 4 +-
.../camel-jooq/src/main/docs/jooq-component.adoc | 3 +
.../camel/component/jooq/JooqConfiguration.java | 2 +-
.../apache/camel/component/jooq/JooqEndpoint.java | 9 +-
.../camel/component/jooq/JooqComponentTest.java | 12 +
.../component/jooq/JooqProducerEmptyBodyTest.java | 93 +++
.../org/apache/camel/component/jt400/jt400.json | 2 +-
.../camel-jt400/src/main/docs/jt400-component.adoc | 8 +-
.../camel/component/jt400/Jt400Endpoint.java | 23 +-
.../camel/component/jt400/Jt400PgmProducer.java | 31 +-
.../component/jt400/Jt400PgmProducerTest.java | 130 ++++
.../support/resume/KafkaResumeAdapter.java | 8 +-
.../support/resume/KafkaResumeAdapterTest.java | 61 +-
.../src/main/docs/language-component.adoc | 44 ++
.../camel/component/language/LanguageEndpoint.java | 5 +-
.../camel/component/language/LanguageProducer.java | 18 +-
.../observability/AsyncProcessorSpanTest.java | 89 +++
.../apache/camel/component/mina/MinaProducer.java | 10 +-
.../mina/MinaDisconnectOnTimeOutTest.java | 7 +-
.../mongodb/support/InMemoryStringResumeCache.java | 9 +-
.../src/main/docs/mybatis-component.adoc | 6 +
.../camel/component/mybatis/MyBatisProducer.java | 23 +-
.../mybatis/MyBatisInOutKeepsBodyTest.java | 127 ++++
.../mybatis/MyBatisInsertWithRollbackTest.java | 8 +-
.../component/mybatis/MyBatisNullBodyTest.java | 102 +++
.../org/apache/camel/component/mybatis/Account.xml | 15 +
.../src/main/docs/netty-http-component.adoc | 11 +
.../netty/http/HttpServerInitializerFactory.java | 9 +-
.../http/handlers/HttpServerChannelHandler.java | 31 +-
.../http/NettyHttpResponseCannotBeBuiltTest.java | 96 +++
...NettyHttpSSLServerHostnameVerificationTest.java | 132 ++++
.../camel-netty/src/main/docs/netty-component.adoc | 10 +
.../camel/component/netty/NettyConfiguration.java | 10 +
.../camel/component/netty/NettyPayloadHelper.java | 71 +-
.../netty/handlers/ClientChannelHandler.java | 9 +
.../netty/handlers/ServerChannelHandler.java | 44 +-
.../handlers/ServerResponseFutureListener.java | 9 +
.../netty/NettyDefaultCodecReplyTest.java | 91 +++
.../netty/NettyProducerSyncFalseReplyTest.java | 64 ++
.../netty/NettyReplyWriteFailureTest.java | 79 +++
...TransferExchangeAllowSerializedHeadersTest.java | 135 ++++
.../camel/component/netty/NettyUseByteBufTest.java | 86 +++
.../opentelemetry2/AsyncProcessorSpanTest.java | 119 ++++
.../camel/component/optaplanner/optaplanner.json | 4 +-
.../src/main/docs/optaplanner-component.adoc | 12 +-
.../optaplanner/OptaPlannerComponent.java | 29 +
.../optaplanner/OptaPlannerConfiguration.java | 3 +-
.../component/optaplanner/OptaPlannerEndpoint.java | 75 +-
.../component/optaplanner/OptaPlannerProducer.java | 14 +-
.../OptaPlannerConfigFileSolverManagerTest.java | 79 +++
.../OptaPlannerConsumerCamelContextTest.java | 88 +++
.../optaplanner/OptaPlannerSyncConsumerTest.java | 63 ++
.../component/optaplanner/solverConfigQuick.xml | 38 +
.../pg/replication/slot/pg-replication-slot.json | 5 +-
.../main/docs/pg-replication-slot-component.adoc | 3 +
.../slot/PgReplicationSlotConstants.java} | 19 +-
.../slot/PgReplicationSlotConsumer.java | 2 +-
.../slot/PgReplicationSlotEndpoint.java | 6 +-
.../PgReplicationSlotConsumerReconnectTest.java | 21 +-
.../slot/PgReplicationSlotConsumerTest.java | 68 ++
.../src/main/docs/platform-http-vertx.adoc | 7 +
.../http/vertx/VertxPlatformHttpSupport.java | 15 +-
.../VertxPlatformHttpSingleValueResponseTest.java | 142 ++++
.../component/pubnub/PubNubConverterLoader.java | 60 ++
.../org/apache/camel/component/pubnub/pubnub.json | 2 +-
.../services/org/apache/camel/TypeConverterLoader | 2 +
.../src/main/docs/pubnub-component.adoc | 3 +
.../camel/component/pubnub/PubNubConverter.java | 45 ++
.../camel/component/pubnub/PubNubEndpoint.java | 3 +-
.../camel/component/pubnub/PubNubProducer.java | 10 +-
.../component/pubnub/PubNubConverterTest.java | 63 ++
.../component/pubnub/PubNubEmptyBodyTest.java | 92 +++
.../component/pubnub/PubNubSubscriberTest.java | 3 +
...PersistentStoreRestartAppChangeOptionsTest.java | 18 +-
...PersistentStoreRestartAppChangeOptionsTest1.xml | 2 +-
...PersistentStoreRestartAppChangeOptionsTest2.xml | 2 +-
.../component/robotframework/robotframework.json | 2 +-
.../src/main/docs/robotframework-component.adoc | 24 +-
.../robotframework/RobotFrameworkCamelUtils.java | 48 +-
.../robotframework/RobotFrameworkEndpoint.java | 2 +-
.../RobotFrameworkCamelUtilsTest.java | 46 ++
.../RobotFrameworkComponentTest.java | 24 +
.../robotframework/RobotFrameworkConsumerTest.java | 52 ++
.../set_variable_camel_no_body.robot | 27 +
components/camel-rocketmq/pom.xml | 4 +-
.../apache/camel/component/rocketmq/rocketmq.json | 44 +-
.../src/main/docs/rocketmq-component.adoc | 20 +-
.../component/rocketmq/RocketMQComponent.java | 8 +-
.../component/rocketmq/RocketMQConstants.java | 40 +-
.../camel/component/rocketmq/RocketMQEndpoint.java | 8 +-
.../camel/component/rocketmq/RocketMQProducer.java | 30 +-
.../rocketmq/RocketMQProducerSendFailureTest.java | 44 +-
.../camel-rss/src/main/docs/rss-component.adoc | 5 +
.../apache/camel/component/rss/RssEndpoint.java | 12 +-
.../component/rss/RssEntryCloneFailureTest.java | 136 ++++
.../camel/component/salesforce/salesforce.json | 6 +-
.../src/main/docs/salesforce-component.adoc | 2 +-
.../src/main/docs/salesforce-rest-api.adoc | 3 +
.../component/salesforce/SalesforceEndpoint.java | 9 +-
.../salesforce/SalesforceEndpointConfig.java | 5 +-
.../internal/processor/CompositeApiProcessor.java | 20 +-
.../CompositeSObjectCollectionsProcessor.java | 3 +
.../internal/processor/JsonRestProcessor.java | 13 +
.../internal/processor/RawProcessor.java | 4 +-
.../salesforce/ProducerRequestBodyTest.java | 205 ++++++
.../internal/processor/JsonRestProcessorTest.java | 49 ++
components/camel-sap-netweaver/pom.xml | 7 +
.../component/sap/netweaver/NetWeaverProducer.java | 17 +-
.../sap/netweaver/NetWeaverProducerTest.java | 118 ++++
.../servicenow/AbstractServiceNowProcessor.java | 11 +-
.../component/servicenow/ServiceNowUnwrapTest.java | 117 ++++
.../apache/camel/component/servlet/servlet.json | 2 +-
.../component/servlet/AttachmentHttpBinding.java | 11 +
.../component/servlet/MultipartUploadTest.java | 21 +
...rvletChunkedNonStreamBodyAndFormStreamTest.java | 110 +++
.../servlet/ServletGzipNonStreamBodyTest.java | 121 ++++
.../ServletMapHttpMessageBodyFalseTest.java | 65 ++
.../org/apache/camel/component/sjms/sjms.json | 2 +-
.../camel-sjms/src/main/docs/sjms-component.adoc | 8 +-
.../apache/camel/component/sjms/SjmsEndpoint.java | 5 +-
.../sjms/consumer/EndpointMessageListener.java | 6 +
.../camel/component/sjms/jms/JmsBinding.java | 54 +-
.../consumer/InOutConsumerReplyFailureTest.java | 106 +++
.../sjms/producer/JmsMessageTypeTest.java | 37 +
.../sjms/producer/UnmappableBodyTest.java | 97 +++
.../org/apache/camel/component/sjms2/sjms2.json | 2 +-
.../camel-sjms2/src/main/docs/sjms2-component.adoc | 8 +-
.../camel/component/sjms2/Sjms2Endpoint.java | 5 +-
.../smooks/converter/SourceConverterLoader.java | 2 +-
.../src/main/docs/smooks-component.adoc | 4 +-
.../camel/component/smooks/SmooksProcessor.java | 69 +-
.../smooks/converter/SourceConverter.java | 23 +-
.../camel/component/smooks/routing/BeanRouter.java | 8 +-
.../component/smooks/SmooksReaderBodyTest.java | 204 ++++++
.../component/smooks/routing/BeanRouterTest.java | 47 ++
.../camel/component/spring/batch/spring-batch.json | 4 +-
.../src/main/docs/spring-batch-component.adoc | 8 +-
.../spring/batch/SpringBatchConstants.java | 3 +-
.../spring/batch/SpringBatchEndpoint.java | 2 +-
.../spring/batch/SpringBatchProducer.java | 15 +-
.../spring/batch/SpringBatchEndpointTest.java | 31 +
.../src/main/docs/spring-ws-component.adoc | 8 +
.../spring/ws/SpringWebserviceConsumer.java | 4 +-
.../spring/ws/SpringWebserviceHelper.java | 27 +
.../spring/ws/SpringWebserviceMessage.java | 24 +-
.../spring/ws/SpringWebserviceProducer.java | 3 +-
.../component/spring/ws/ConsumerReplyBodyTest.java | 137 ++++
.../spring/ws/ProducerLocalRouteTest.java | 45 ++
.../spring/ws/ConsumerReplyBodyTest-context.xml | 29 +
.../spring/ws/ProducerLocalRouteTest-context.xml | 13 +-
.../org/apache/camel/component/sql/sql.json | 4 +-
.../camel/component/sql/stored/sql-stored.json | 6 +-
.../camel-sql/src/main/docs/sql-component.adoc | 4 +
.../src/main/docs/sql-stored-component.adoc | 18 +
.../apache/camel/component/sql/SqlConstants.java | 5 +-
.../apache/camel/component/sql/SqlEndpoint.java | 4 +-
.../apache/camel/component/sql/SqlProducer.java | 20 +-
.../component/sql/stored/SqlStoredConstants.java | 6 +-
.../component/sql/stored/SqlStoredEndpoint.java | 8 +-
.../component/sql/stored/SqlStoredProducer.java | 21 +-
.../camel/component/sql/SqlProducerBatchTest.java | 198 ++++++
.../component/sql/stored/ProducerBatchTest.java | 44 ++
.../org/apache/camel/component/stax/stax.json | 2 +-
.../camel-stax/src/main/docs/stax-component.adoc | 1 +
.../apache/camel/component/stax/StAXEndpoint.java | 8 +-
.../apache/camel/component/stax/StAXProcessor.java | 36 +-
.../camel/component/stax/StAXBodyTypesTest.java | 153 ++++
.../org/apache/camel/component/stripe/stripe.json | 4 +-
.../src/main/docs/stripe-component.adoc | 9 +-
.../camel/component/stripe/StripeConstants.java | 4 +-
.../camel/component/stripe/StripeEndpoint.java | 6 +-
.../camel/component/stripe/StripeProducer.java | 116 ++--
.../stripe/StripeProducerRequestTest.java | 198 ++++++
.../syslog/netty/Rfc5425FrameDecoder.java | 74 +-
.../syslog/netty/Rfc5425FrameDecoderTest.java | 130 ++++
.../camel/telemetrydev/AsyncProcessorSpanTest.java | 92 +++
.../TraceProcessorsInterceptStrategy.java | 55 +-
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../decorators/AbstractSpanDecorator.java | 21 +-
.../camel/telemetry/AsyncProcessorSpanTest.java | 284 ++++++++
.../telemetry/ProcessorSpanBeginFailureTest.java | 123 ++++
.../telemetry/ProcessorSpanEndFailureTest.java | 106 +++
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 ++-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../org/apache/camel/component/citrus/citrus.json | 2 +-
.../src/main/docs/citrus-component.adoc | 10 +
.../camel/component/citrus/CitrusEndpoint.java | 11 +-
.../citrus/CitrusValidationProcessor.java | 38 +-
.../citrus/CitrusValidateBodyTypesTest.java | 181 +++++
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../tracing/decorators/AbstractSpanDecorator.java | 21 +-
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 ++-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../directmessage/twitter-directmessage.json | 2 +-
.../twitter/timeline/twitter-timeline.json | 2 +-
.../main/docs/twitter-directmessage-component.adoc | 3 +-
.../directmessage/DirectMessageProducer.java | 4 +-
.../TwitterDirectMessageEndpoint.java | 2 +-
.../twitter/timeline/TwitterTimelineEndpoint.java | 2 +-
.../component/twitter/util/TwitterConverter.java | 3 +
.../twitter/DirectMessageProducerTest.java | 77 +++
.../component/twitter/TwitterConverterTest.java | 55 ++
.../twitter/TwitterTimelineEndpointTest.java | 41 ++
.../src/main/docs/undertow-component.adoc | 11 +
.../undertow/DefaultUndertowHttpBinding.java | 30 +-
.../camel/component/undertow/UndertowConsumer.java | 23 +-
.../camel/component/undertow/UndertowHelper.java | 45 ++
.../camel/component/undertow/UndertowProducer.java | 30 +-
.../undertow/UndertowBodyConversionTest.java | 218 ++++++
.../undertow/UndertowSwitchingStatus204Test.java | 6 +-
.../org/apache/camel/component/vertx/vertx.json | 8 +-
.../camel-vertx/src/main/docs/vertx-component.adoc | 19 +-
.../camel/component/vertx/VertxBodyHelper.java | 47 ++
.../camel/component/vertx/VertxConsumer.java | 12 +-
.../camel/component/vertx/VertxEndpoint.java | 24 +-
.../camel/component/vertx/VertxProducer.java | 34 +-
.../camel/component/vertx/VertxNullBodyTest.java | 140 ++++
.../vertx/VertxRequestReplyFailureTest.java | 18 +-
.../vertx/VertxRequestReplyStreamTest.java | 90 +++
.../whatsapp/WhatsAppWebhookProcessor.java | 44 +-
.../whatsapp/WhatsAppWebhookProcessorTest.java | 163 +++++
.../component/whatsapp/WhatsAppWebhookTest.java | 16 +
.../camel/component/wordpress/wordpress.json | 2 +-
.../src/main/docs/wordpress-component.adoc | 5 +
.../component/wordpress/WordpressEndpoint.java | 6 +-
.../producer/AbstractWordpressProducer.java | 37 +-
.../wordpress/producer/WordpressPostProducer.java | 8 +-
.../wordpress/producer/WordpressUserProducer.java | 10 +-
.../wordpress/WordpressPostOperationTest.java | 63 ++
.../wordpress/WordpressUserOperationTest.java | 46 ++
.../test/WordpressServerHttpRequestHandler.java | 20 +
.../camel/component/zendesk/ZendeskComponent.java | 4 +
.../zendesk/AbstractZendeskTestSupport.java | 8 +-
.../component/zendesk/ZendeskApiNameTest.java | 101 +++
.../org/apache/camel/resume/cache/ResumeCache.java | 11 +-
.../org/apache/camel/impl/engine/DefaultRoute.java | 5 +-
.../camel/impl/engine/DefaultShutdownStrategy.java | 85 ++-
core/camel-core-processor/pom.xml | 7 +
.../java/org/apache/camel/processor/Splitter.java | 13 +-
.../errorhandler/RedeliveryErrorHandler.java | 98 ++-
.../processor/resume/TransientResumeStrategy.java | 13 +-
.../resume/TransientResumeStrategyCacheTest.java | 104 +++
.../converter/stream/StreamCacheConverterTest.java | 27 +-
...aultShutdownStrategyConcurrentShutdownTest.java | 420 +++++++++++
.../ConstantLanguageBinaryResourceTest.java | 40 ++
.../processor/SplitterTestResumeStrategy.java | 9 +-
.../camel/processor/SplitterWatermarkTest.java | 19 +
.../SimpleTaskProcessorThrowsPooledTest.java | 38 +
.../SimpleTaskProcessorThrowsTest.java | 341 +++++++++
.../SimpleTaskProcessorThrowsTestSupport.java | 199 ++++++
.../throttle/requests/ThrottlingGroupingTest.java | 15 +-
.../org/apache/camel/support/PatternHelper.java | 26 +-
.../apache/camel/support/PatternHelperTest.java | 91 +++
.../apache/camel/util/ImportantHeaderUtils.java | 2 +-
.../main/java/org/apache/camel/util/StopWatch.java | 4 +-
.../util/concurrent/BoundedExecutorService.java | 63 +-
.../java/org/apache/camel/util/StopWatchTest.java | 36 +
.../concurrent/BoundedExecutorServiceTest.java | 261 +++++++
.../apache/camel/converter/jaxp/XmlConverter.java | 16 +-
.../camel/util/xml/StreamSourceConverter.java | 14 +-
design/chaos.adoc | 28 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 32 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_21.adoc | 2 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 30 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 770 +++++++++++++++++++++
.../modules/ROOT/pages/camel-jbang-mcp.adoc | 7 +-
.../modules/ROOT/pages/camel-jbang-running.adoc | 6 +
.../modules/ROOT/pages/camel-jbang-test.adoc | 18 +-
.../modules/ROOT/pages/threading-model.adoc | 9 +
...BedrockAgentRuntimeComponentBuilderFactory.java | 6 +-
.../dsl/AwsBedrockComponentBuilderFactory.java | 6 +-
.../dsl/AzureFunctionsComponentBuilderFactory.java | 21 +
.../dsl/RocketmqComponentBuilderFactory.java | 8 +-
.../dsl/SalesforceComponentBuilderFactory.java | 6 +-
.../builder/endpoint/EndpointHeaderBuilders.java | 53 ++
.../builder/endpoint/StaticEndpointBuilders.java | 40 +-
.../AtmosphereWebsocketEndpointBuilderFactory.java | 44 +-
.../BedrockAgentRuntimeEndpointBuilderFactory.java | 11 +-
.../dsl/BedrockEndpointBuilderFactory.java | 23 +-
.../endpoint/dsl/BonitaEndpointBuilderFactory.java | 36 +
.../dsl/ClickHouseEndpointBuilderFactory.java | 4 +-
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 15 +
.../endpoint/dsl/DuckDbEndpointBuilderFactory.java | 7 +-
.../endpoint/dsl/FlinkEndpointBuilderFactory.java | 8 +-
.../dsl/FunctionsEndpointBuilderFactory.java | 36 +
...gleCloudTextToSpeechEndpointBuilderFactory.java | 4 +-
.../dsl/GoogleDriveEndpointBuilderFactory.java | 51 +-
.../dsl/GoogleMailEndpointBuilderFactory.java | 12 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 10 +-
.../dsl/GoogleVertexAIEndpointBuilderFactory.java | 27 +-
.../endpoint/dsl/IggyEndpointBuilderFactory.java | 134 ++++
.../dsl/JettyHttp12EndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/MNSEndpointBuilderFactory.java | 9 +-
.../endpoint/dsl/OSSEndpointBuilderFactory.java | 40 ++
.../dsl/OptaPlannerEndpointBuilderFactory.java | 9 +-
.../PgReplicationSlotEndpointBuilderFactory.java | 39 ++
.../dsl/RocketMQEndpointBuilderFactory.java | 136 ++--
.../dsl/SalesforceEndpointBuilderFactory.java | 36 +-
.../dsl/ServletEndpointBuilderFactory.java | 14 +-
.../dsl/SpringBatchEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java | 5 +-
.../dsl/SqlStoredEndpointBuilderFactory.java | 5 +-
.../endpoint/dsl/StripeEndpointBuilderFactory.java | 3 +-
.../dsl/TwitterTimelineEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/VertxEndpointBuilderFactory.java | 24 +-
dsl/camel-jbang/camel-jbang-core/pom.xml | 5 +-
.../camel/dsl/jbang/core/commands/Debug.java | 1 +
.../apache/camel/dsl/jbang/core/commands/Run.java | 83 ++-
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 85 ++-
.../dsl/jbang/core/commands/ai/CatalogSamples.java | 5 +-
.../core/commands/ai/HeaderPropertyMixups.java | 116 ++++
.../core/commands/ai/IntegrationLauncher.java | 62 +-
.../dsl/jbang/core/commands/ai/OpenApiVerbs.java | 38 +
.../dsl/jbang/core/commands/ai/SimpleChecks.java | 162 ++++-
.../jbang/core/commands/ai/SourceValidator.java | 59 +-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 29 +-
.../dsl/jbang/core/commands/ai/ValidatorFacts.java | 175 ++++-
.../dsl/jbang/core/commands/ai/WriteNotes.java | 401 +++++++++++
.../dsl/jbang/core/commands/process/ListChaos.java | 3 +
.../camel/dsl/jbang/core/common/ExampleHelper.java | 60 +-
.../test/file-processing.citrus.it.yaml | 26 +
.../http-client/test/http-client.citrus.it.yaml | 21 +
.../stock-api/test/stock-api.citrus.it.yaml | 49 ++
.../test/openapi-client.citrus.it.yaml | 39 ++
.../test/openapi-server.citrus.it.yaml | 76 ++
.../test/rest-code-first.citrus.it.yaml | 95 +++
.../test/circuit-breaker.citrus.it.yaml | 26 +
.../test/error-handling.citrus.it.yaml | 36 +
.../rest-api/test/rest-api.citrus.it.yaml | 40 ++
.../quick-start/routes/test/routes.citrus.it.yaml | 19 +
.../splitter/test/splitter.citrus.it.yaml | 19 +
.../timer-log/test/timer-log.citrus.it.yaml | 16 +
.../aggregator/test/aggregator.citrus.it.yaml | 25 +
.../test/content-based-router.citrus.it.yaml | 30 +
.../test/dynamic-routing.citrus.it.yaml | 35 +
.../test/enrich-and-dedupe.citrus.it.yaml | 34 +
.../test/filter-and-multicast.citrus.it.yaml | 30 +
.../order-lines/test/order-lines.citrus.it.yaml | 25 +
.../test/nightly-report.citrus.it.yaml | 16 +
.../test/order-generator.citrus.it.yaml | 24 +
.../test/properties-and-profiles.citrus.it.yaml | 16 +
.../csv-to-json/test/csv-to-json.citrus.it.yaml | 21 +
.../data-mapping/test/data-mapping.citrus.it.yaml | 24 +
.../transform/groovy/test/groovy.citrus.it.yaml | 24 +
.../test/json-transform.citrus.it.yaml | 23 +
.../xml-to-json/test/xml-to-json.citrus.it.yaml | 16 +
.../transform/xslt/test/xslt.citrus.it.yaml | 23 +
.../dsl/jbang/core/commands/CliHelpGoldenTest.java | 4 +-
.../core/commands/CommandInputErrorsTest.java | 25 +
.../dsl/jbang/core/commands/RunDirectoryTest.java | 27 +
.../camel/dsl/jbang/core/commands/RunTest.java | 21 +
.../core/commands/ai/AuthoringToolsCitrusTest.java | 221 ++++++
.../core/commands/ai/AuthoringToolsEditTest.java | 79 +++
.../jbang/core/commands/ai/CatalogSamplesTest.java | 21 +
.../core/commands/ai/ExampleToolsRegistryTest.java | 54 +-
.../core/commands/ai/HeaderPropertyMixupsTest.java | 61 ++
.../core/commands/ai/IntegrationLauncherTest.java | 70 ++
.../commands/ai/SourceValidatorSimpleTest.java | 75 ++
.../jbang/core/commands/ai/ValidatorFactsTest.java | 105 +++
.../dsl/jbang/core/commands/ai/WriteNotesTest.java | 207 ++++++
.../jbang/core/commands/process/ListChaosTest.java | 28 +
.../dsl/jbang/core/common/ExampleHelperTest.java | 29 +
.../jbang/core/common/ExampleRoutesLoadTest.java | 6 +-
.../golden/citrus/test/orders.citrus.it.yaml | 22 +
.../src/test/resources/golden/cli-help.txt | 19 +-
.../jbang/core/commands/mcp/AuthoringTools.java | 2 +-
.../dsl/jbang/core/commands/mcp/ExampleTools.java | 9 +-
.../core/commands/mcp/McpServerInstructions.java | 4 +
.../core/commands/mcp/AuthoringToolsTest.java | 24 +
.../jbang/core/commands/mcp/ExampleToolsTest.java | 16 +
.../commands/mcp/McpServerInstructionsTest.java | 16 +
.../org/apache/camel/dsl/jbang/run/RunFiles.java | 114 ++-
.../apache/camel/dsl/jbang/run/RunPipeline.java | 7 +-
.../camel/dsl/jbang/run/common/ExportHelper.java | 6 +-
.../camel/dsl/jbang/run/export/Exporter.java | 1 -
.../apache/camel/dsl/jbang/run/RunFilesTest.java | 122 ++++
dsl/camel-jbang/camel-launcher/pom.xml | 23 +
.../camel/dsl/yaml/validator/JsonPathText.java | 147 ++++
.../camel/dsl/yaml/validator/ProjectFacts.java | 16 +-
.../camel/dsl/yaml/validator/RouteGraph.java | 81 +++
.../camel/dsl/yaml/validator/SchemaHints.java | 91 +++
.../camel/dsl/yaml/validator/TextBodyFlow.java | 351 ++++++++--
.../camel/dsl/yaml/validator/YamlValidator.java | 256 ++++++-
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 177 ++++-
.../validator/YamlValidatorPropertyHintTest.java | 365 ++++++++++
parent/pom.xml | 48 +-
pom.xml | 2 +-
.../rocketmq/services/RocketMQBrokerContainer.java | 72 +-
906 files changed, 36824 insertions(+), 2914 deletions(-)
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-atmosphere-websocket/src/test/java/org/apache/camel/component/atmosphere/websocket/WebsocketQueryParameterTest.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-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/stream/Ai21StreamParser.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/stream/NovaStreamParser.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/test/java/org/apache/camel/component/aws2/bedrock/agentruntime/BedrockAgentRuntimeProducerOperationTest.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/test/java/org/apache/camel/component/aws2/bedrock/runtime/BedrockProducerRequestTest.java
create mode 100644
components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerResultHeadersTest.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
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-bonita/src/main/java/org/apache/camel/component/bonita/BonitaConstants.java}
(69%)
create mode 100644
components/camel-bonita/src/test/java/org/apache/camel/component/bonita/BonitaStartProducerTest.java
create mode 100644
components/camel-camunda/src/test/java/org/apache/camel/component/camunda/CamundaProducerTest.java
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosLifecycle.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosLifecycleStartupTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosLifecycleTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosNettyHttpFaultTest.java
create mode 100644
components/camel-clickup/src/main/java/org/apache/camel/component/clickup/model/GenericEvent.java
create mode 100644
components/camel-clickup/src/test/resources/messages/events/task-created.json
create mode 100644
components/camel-cxf/camel-cxf-rest/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumerUnchangedBodyTest.java
copy
components/{camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/BedrockOperations.java
=>
camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/BodyTypeService.java}
(71%)
create mode 100644
components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfBodyTypesTest.java
create mode 100644
components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/mongodb/DebeziumMongodbEndpointTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorVmSharedQueueReferenceTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/vm/DisruptorVmComponentStartCounterTest.java
create mode 100644
components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/routing/DynamicRouterRemoveRouteTest.java
create mode 100644
components/camel-ehcache/src/test/java/org/apache/camel/component/ehcache/EhcacheDefaultsTest.java
create mode 100644
components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetRow.java
create mode 100644
components/camel-flatpack/src/test/java/org/apache/camel/component/flatpack/FlatpackSplitRowsTest.java
create mode 100644
components/camel-flink/src/test/java/org/apache/camel/component/flink/DataStreamComponentOptionsAndCollectTest.java
create mode 100644
components/camel-flowable/src/test/java/org/apache/camel/component/flowable/FlowableProducerChannelNotDeployedTest.java
create mode 100644
components/camel-flowable/src/test/resources/channel/userRouteChannel.channel
create mode 100644
components/camel-fop/src/test/java/org/apache/camel/component/fop/FopBodyTest.java
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-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQProducerBodyTest.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-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-iggy/src/test/java/org/apache/camel/component/iggy/IggyMessageBodyTest.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-jms/src/test/java/org/apache/camel/component/jms/JmsUnmappableBodyTest.java
create mode 100644
components/camel-jooq/src/test/java/org/apache/camel/component/jooq/JooqProducerEmptyBodyTest.java
create mode 100644
components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmProducerTest.java
create mode 100644
components/camel-micrometer-observability/src/test/java/org/apache/camel/micrometer/observability/AsyncProcessorSpanTest.java
create mode 100644
components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisInOutKeepsBodyTest.java
create mode 100644
components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisNullBodyTest.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/NettyDefaultCodecReplyTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyProducerSyncFalseReplyTest.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/NettyUseByteBufTest.java
create mode 100644
components/camel-opentelemetry2/src/test/java/org/apache/camel/opentelemetry2/AsyncProcessorSpanTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerConfigFileSolverManagerTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerConsumerCamelContextTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerSyncConsumerTest.java
create mode 100644
components/camel-optaplanner/src/test/resources/org/apache/camel/component/optaplanner/solverConfigQuick.xml
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConstants.java}
(57%)
create mode 100644
components/camel-pg-replication-slot/src/test/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumerTest.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-pubnub/src/generated/java/org/apache/camel/component/pubnub/PubNubConverterLoader.java
create mode 100644
components/camel-pubnub/src/generated/resources/META-INF/services/org/apache/camel/TypeConverterLoader
create mode 100644
components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubConverter.java
create mode 100644
components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubConverterTest.java
create mode 100644
components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubEmptyBodyTest.java
create mode 100644
components/camel-robotframework/src/test/java/org/apache/camel/component/robotframework/RobotFrameworkConsumerTest.java
create mode 100644
components/camel-robotframework/src/test/resources/org/apache/camel/component/robotframework/set_variable_camel_no_body.robot
create mode 100644
components/camel-rss/src/test/java/org/apache/camel/component/rss/RssEntryCloneFailureTest.java
create mode 100644
components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/ProducerRequestBodyTest.java
create mode 100644
components/camel-sap-netweaver/src/test/java/org/apache/camel/component/sap/netweaver/NetWeaverProducerTest.java
create mode 100644
components/camel-servicenow/camel-servicenow-component/src/test/java/org/apache/camel/component/servicenow/ServiceNowUnwrapTest.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/consumer/InOutConsumerReplyFailureTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/UnmappableBodyTest.java
create mode 100644
components/camel-smooks/src/test/java/org/apache/camel/component/smooks/SmooksReaderBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ws/src/test/java/org/apache/camel/component/spring/ws/ConsumerReplyBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ws/src/test/resources/org/apache/camel/component/spring/ws/ConsumerReplyBodyTest-context.xml
create mode 100644
components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerBatchTest.java
create mode 100644
components/camel-stax/src/test/java/org/apache/camel/component/stax/StAXBodyTypesTest.java
create mode 100644
components/camel-stripe/src/test/java/org/apache/camel/component/stripe/StripeProducerRequestTest.java
create mode 100644
components/camel-syslog/src/test/java/org/apache/camel/component/syslog/netty/Rfc5425FrameDecoderTest.java
create mode 100644
components/camel-telemetry-dev/src/test/java/org/apache/camel/telemetrydev/AsyncProcessorSpanTest.java
create mode 100644
components/camel-telemetry/src/test/java/org/apache/camel/telemetry/AsyncProcessorSpanTest.java
create mode 100644
components/camel-telemetry/src/test/java/org/apache/camel/telemetry/ProcessorSpanBeginFailureTest.java
create mode 100644
components/camel-telemetry/src/test/java/org/apache/camel/telemetry/ProcessorSpanEndFailureTest.java
create mode 100644
components/camel-test/camel-test-citrus/src/test/java/org/apache/camel/component/citrus/CitrusValidateBodyTypesTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageProducerTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/TwitterConverterTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/TwitterTimelineEndpointTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/UndertowBodyConversionTest.java
create mode 100644
components/camel-vertx/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxBodyHelper.java
create mode 100644
components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxNullBodyTest.java
create mode 100644
components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyStreamTest.java
create mode 100644
components/camel-whatsapp/src/test/java/org/apache/camel/component/whatsapp/WhatsAppWebhookProcessorTest.java
create mode 100644
components/camel-zendesk/src/test/java/org/apache/camel/component/zendesk/ZendeskApiNameTest.java
create mode 100644
core/camel-core-processor/src/test/java/org/apache/camel/processor/resume/TransientResumeStrategyCacheTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultShutdownStrategyConcurrentShutdownTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/SimpleTaskProcessorThrowsPooledTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/SimpleTaskProcessorThrowsTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/SimpleTaskProcessorThrowsTestSupport.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ai/WriteNotes.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/connect/file-processing/test/file-processing.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/connect/http-client/test/http-client.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/connect/stock-api/test/stock-api.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/contracts/openapi-client/test/openapi-client.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/contracts/openapi-server/test/openapi-server.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/contracts/rest-code-first/test/rest-code-first.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/fail-well/circuit-breaker/test/circuit-breaker.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/fail-well/error-handling/test/error-handling.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/rest-api/test/rest-api.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/routes/test/routes.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/splitter/test/splitter.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/timer-log/test/timer-log.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/aggregator/test/aggregator.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/content-based-router/test/content-based-router.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/dynamic-routing/test/dynamic-routing.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/enrich-and-dedupe/test/enrich-and-dedupe.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/filter-and-multicast/test/filter-and-multicast.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/order-lines/test/order-lines.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/run/nightly-report/test/nightly-report.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/run/order-generator/test/order-generator.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/run/properties-and-profiles/test/properties-and-profiles.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/csv-to-json/test/csv-to-json.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/data-mapping/test/data-mapping.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/groovy/test/groovy.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/json-transform/test/json-transform.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/xml-to-json/test/xml-to-json.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/xslt/test/xslt.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/commands/ai/AuthoringToolsCitrusTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/commands/ai/WriteNotesTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/golden/citrus/test/orders.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-run/src/test/java/org/apache/camel/dsl/jbang/run/RunFilesTest.java
create mode 100644
dsl/camel-yaml-dsl/camel-yaml-dsl-validator/src/main/java/org/apache/camel/dsl/yaml/validator/JsonPathText.java
