This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/maven/io.opentelemetry.proto-opentelemetry-proto-1.11.1-alpha
in repository https://gitbox.apache.org/repos/asf/camel.git
omit f29a4601387f chore(deps): Bump
io.opentelemetry.proto:opentelemetry-proto
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 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 a3652f661f73 chore(deps): Bump
io.opentelemetry.proto:opentelemetry-proto
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 (f29a4601387f)
\
N -- N -- N
refs/heads/dependabot/maven/io.opentelemetry.proto-opentelemetry-proto-1.11.1-alpha
(a3652f661f73)
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 +-
.../catalog/components/atmosphere-websocket.json | 4 +-
.../components/aws-bedrock-agent-runtime.json | 12 +-
.../camel/catalog/components/aws-bedrock.json | 16 +-
.../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/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 +-
.../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/cxf.json | 4 +-
.../org/apache/camel/catalog/components/cxfrs.json | 4 +-
.../camel/catalog/components/debezium-mongodb.json | 5 +-
.../org/apache/camel/catalog/components/djl.json | 2 +-
.../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 +-
.../catalog/components/ibm-secrets-manager.json | 4 +-
.../camel/catalog/components/ibm-watsonx-ai.json | 2 +-
.../camel/catalog/components/ibm-watsonx-data.json | 2 +-
.../org/apache/camel/catalog/components/iggy.json | 15 +-
.../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/jooq.json | 4 +-
.../org/apache/camel/catalog/components/jt400.json | 2 +-
.../apache/camel/catalog/components/keycloak.json | 4 +-
.../components/langchain4j-embeddingstore.json | 2 +-
.../catalog/components/langchain4j-ingest.json | 2 +-
.../org/apache/camel/catalog/components/ldap.json | 2 +-
.../org/apache/camel/catalog/components/lpr.json | 2 +-
.../camel/catalog/components/netty-http.json | 4 +-
.../org/apache/camel/catalog/components/netty.json | 4 +-
.../org/apache/camel/catalog/components/odata.json | 6 +-
.../camel/catalog/components/optaplanner.json | 4 +-
.../catalog/components/pg-replication-slot.json | 5 +-
.../org/apache/camel/catalog/components/plc4x.json | 2 +-
.../apache/camel/catalog/components/pubnub.json | 2 +-
.../apache/camel/catalog/components/quickfix.json | 4 +-
.../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/splunk-hec.json | 2 +-
.../camel/catalog/components/spring-ai-image.json | 4 +-
.../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 +-
.../apache/camel/catalog/components/tahu-edge.json | 2 +-
.../apache/camel/catalog/components/thrift.json | 2 +-
.../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 +-
.../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-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/bonita-component.adoc | 7 +-
.../camel/catalog/docs/camunda-component.adoc | 41 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 35 +-
.../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/coap-component.adoc | 7 +-
.../camel/catalog/docs/crypto-component.adoc | 9 +
.../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 +
.../apache/camel/catalog/docs/djl-component.adoc | 39 +-
.../camel/catalog/docs/duckdb-component.adoc | 10 +-
.../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-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 +-
.../apache/camel/catalog/docs/iggy-component.adoc | 24 +-
.../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/jooq-component.adoc | 3 +
.../apache/camel/catalog/docs/jt400-component.adoc | 8 +-
.../camel/catalog/docs/keycloak-producer.adoc | 26 +-
.../docs/langchain4j-embeddingstore-component.adoc | 18 +-
.../catalog/docs/langchain4j-ingest-component.adoc | 7 +
.../camel/catalog/docs/language-component.adoc | 44 +
.../apache/camel/catalog/docs/ldap-component.adoc | 12 +-
.../org/apache/camel/catalog/docs/mcp-server.adoc | 11 +-
.../camel/catalog/docs/micrometer-component.adoc | 3 +
.../camel/catalog/docs/mybatis-component.adoc | 6 +
.../apache/camel/catalog/docs/netty-component.adoc | 10 +
.../camel/catalog/docs/netty-http-component.adoc | 11 +
.../apache/camel/catalog/docs/odata-component.adoc | 15 +-
.../camel/catalog/docs/optaplanner-component.adoc | 12 +-
.../docs/pg-replication-slot-component.adoc | 3 +
.../camel/catalog/docs/platform-http-vertx.adoc | 7 +
.../apache/camel/catalog/docs/plc4x-component.adoc | 24 +-
.../camel/catalog/docs/pubnub-component.adoc | 3 +
.../camel/catalog/docs/quickfix-component.adoc | 41 +-
.../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 +
.../camel/catalog/docs/simple-functions.adoc | 4 +-
.../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/splunk-hec-component.adoc | 4 +
.../catalog/docs/spring-ai-image-component.adoc | 23 +-
.../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 +-
.../camel/catalog/docs/tahu-edge-component.adoc | 8 +
.../camel/catalog/docs/tahu-host-component.adoc | 15 +-
.../camel/catalog/docs/thrift-component.adoc | 7 +
.../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 +-
.../component/ai/resource/AiResourceExecutor.java | 25 +-
.../ai/resource/AiResourceExecutorTest.java | 38 +
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 ++++++
.../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 ++
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 +-
.../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 ++++++
.../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 +++++++
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 +++++++
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 +-
.../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 +
.../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 ++++
.../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 +-
.../MultipleConsumerSynchronizedExchange.java | 26 +-
...DisruptorMultipleConsumersOnCompletionTest.java | 161 ++++
.../MultipleConsumerSynchronizedExchangeTest.java | 103 +++
.../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 +++
.../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 +
.../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 +
.../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 ++
.../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/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 +++
.../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 +
.../src/main/docs/language-component.adoc | 44 +
.../camel/component/language/LanguageEndpoint.java | 5 +-
.../camel/component/language/LanguageProducer.java | 18 +-
.../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 -
.../src/main/docs/micrometer-component.adoc | 3 +
.../component/micrometer/CounterProducer.java | 16 +
.../component/micrometer/CounterRouteTest.java | 110 +++
.../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 +
.../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/HttpServerInitializerFactory.java | 9 +-
.../http/handlers/HttpServerChannelHandler.java | 31 +-
.../http/NettyHttpResponseCannotBeBuiltTest.java | 96 ++
...NettyHttpSSLServerHostnameVerificationTest.java | 132 +++
.../org/apache/camel/component/netty/netty.json | 4 +-
.../camel-netty/src/main/docs/netty-component.adoc | 10 +
.../camel/component/netty/NettyConfiguration.java | 21 +-
.../camel/component/netty/NettyPayloadHelper.java | 124 ++-
.../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 +++
...NettyTransferExchangeConnectionHeadersTest.java | 157 ++++
.../camel/component/netty/NettyUseByteBufTest.java | 86 ++
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 +++
.../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 +++
.../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 ++++
.../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 +
.../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 +-
.../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/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/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 ++++
.../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 +++++
.../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/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 ++++
.../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 ++
.../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 +-
.../vertx/http/VertxHttpRequestBodyTypesTest.java | 4 +-
.../http/VertxHttpRequestWithPayloadTest.java | 4 +-
.../vertx/http/VertxHttpSerializedBodyTest.java | 4 +-
.../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 +++
.../modules/languages/pages/simple-functions.adoc | 4 +-
.../language/simple/SimpleFunctionHelper.java | 22 +-
.../simple/functions/JoinFunctionFactory.java | 25 +-
.../org/apache/camel/processor/RoutingSlip.java | 176 ++--
.../converter/stream/StreamCacheConverterTest.java | 27 +-
.../ScheduledThreadPoolRemoveOnCancelTest.java | 59 ++
.../ConstantLanguageBinaryResourceTest.java | 40 +
.../simple/functions/JoinFunctionFactoryTest.java | 47 +
.../camel/processor/ThreadsKeepAliveTimeTest.java | 3 +
.../DynamicRouterEventNotifierTest.java | 15 +
.../routingslip/RoutingSlipEventNotifierTest.java | 15 +
.../routingslip/RoutingSlipSentEventOrderTest.java | 163 ++++
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 ++
.../apache/camel/util/ImportantHeaderUtils.java | 2 +-
.../util/concurrent/BoundedExecutorService.java | 63 +-
.../concurrent/BoundedExecutorServiceTest.java | 261 ++++++
.../apache/camel/converter/jaxp/XmlConverter.java | 16 +-
.../camel/util/xml/StreamSourceConverter.java | 14 +-
design/chaos.adoc | 6 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 17 +
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 17 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 962 +++++++++++++++++++++
.../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 | 13 +-
.../modules/ROOT/pages/virtual-threads.adoc | 5 +-
...BedrockAgentRuntimeComponentBuilderFactory.java | 6 +-
.../dsl/AwsBedrockComponentBuilderFactory.java | 6 +-
.../dsl/AzureFunctionsComponentBuilderFactory.java | 21 +
.../dsl/NettyComponentBuilderFactory.java | 8 +-
.../dsl/NettyHttpComponentBuilderFactory.java | 8 +-
.../dsl/RocketmqComponentBuilderFactory.java | 8 +-
.../dsl/SalesforceComponentBuilderFactory.java | 6 +-
.../builder/endpoint/EndpointHeaderBuilders.java | 53 ++
.../builder/endpoint/StaticEndpointBuilders.java | 58 +-
.../AtmosphereWebsocketEndpointBuilderFactory.java | 44 +-
.../BedrockAgentRuntimeEndpointBuilderFactory.java | 11 +-
.../dsl/BedrockEndpointBuilderFactory.java | 23 +-
.../endpoint/dsl/BonitaEndpointBuilderFactory.java | 36 +
.../dsl/ClickHouseEndpointBuilderFactory.java | 4 +-
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 15 +
.../DigitalSignatureEndpointBuilderFactory.java | 3 +-
.../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/JGroupsRaftEndpointBuilderFactory.java | 279 ++++++
.../dsl/JettyHttp12EndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/LdapEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/MNSEndpointBuilderFactory.java | 9 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 48 +-
.../dsl/NettyHttpEndpointBuilderFactory.java | 48 +-
.../endpoint/dsl/ODataEndpointBuilderFactory.java | 2 +
.../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 | 92 +-
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 50 +-
.../core/commands/ai/IntegrationLauncher.java | 62 +-
.../jbang/core/commands/ai/SourceValidator.java | 59 +-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 29 +-
.../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 | 16 +
.../commands/RunMcpStdioConfigurationTest.java | 58 ++
.../camel/dsl/jbang/core/commands/RunTest.java | 21 +
.../core/commands/ai/AuthoringToolsCitrusTest.java | 221 +++++
.../core/commands/ai/ExampleToolsRegistryTest.java | 54 +-
.../core/commands/ai/IntegrationLauncherTest.java | 70 ++
.../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 +-
.../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 | 17 +-
.../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 +-
.../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 +
.../commands/tui/AiCliCommandExecutorTest.java | 4 +
.../jbang/core/commands/tui/BorderRenderTest.java | 3 +
.../core/commands/tui/MonitorStartupTest.java | 12 +-
.../core/commands/tui/ShellPanelLifecycleTest.java | 8 +
.../org/apache/camel/dsl/jbang/run/RunFiles.java | 114 ++-
.../apache/camel/dsl/jbang/run/RunFilesTest.java | 122 +++
dsl/camel-jbang/camel-launcher/pom.xml | 23 +
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 10 +-
parent/pom.xml | 22 +-
pom.xml | 2 +-
.../infra/cli/services/CliLocalProcessService.java | 15 +-
.../camel/test/infra/cli/services/CliService.java | 8 +
.../test/infra/cli/services/CliServiceFactory.java | 10 +
.../rocketmq/services/RocketMQBrokerContainer.java | 72 +-
1082 files changed, 37830 insertions(+), 3576 deletions(-)
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-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-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
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/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-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-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/DisruptorMultipleConsumersOnCompletionTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/MultipleConsumerSynchronizedExchangeTest.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-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-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-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-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-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-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/NettyTransferExchangeConnectionHeadersTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseByteBufTest.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-printer/src/test/java/org/apache/camel/component/printer/PrinterProducerBodyTest.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-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjInOutTest.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-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-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-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-test/camel-test-citrus/src/test/java/org/apache/camel/component/citrus/CitrusValidateBodyTypesTest.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-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/src/test/java/org/apache/camel/impl/ScheduledThreadPoolRemoveOnCancelTest.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/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/RunMcpStdioConfigurationTest.java
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/resources/golden/citrus/test/orders.citrus.it.yaml
copy
components/camel-dfdl/src/main/java/org/apache/camel/component/dfdl/DfdlParseException.java
=>
dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/InfrastructureListITCase.java
(70%)
copy
dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/{CamelDebugITCase.java
=> StubITCase.java} (65%)
create mode 100644
dsl/camel-jbang/camel-jbang-run/src/test/java/org/apache/camel/dsl/jbang/run/RunFilesTest.java
