This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26298-mcp-stdio-startup
in repository https://gitbox.apache.org/repos/asf/camel.git
from bf99669f7098 CAMEL-26298: camel-mcp-server - Test that stream:out
stays out of the MCP stream
add 44bf7ffec6e8 CAMEL-26436: camel-chaos - control a running application
from the Camel CLI: a chaos dev console, camel cmd chaos-* and camel get chaos
(#28788)
add b1ebadeffa08 CAMEL-26476: camel-core - Split EIP: a nested split
corrupts the processed items of the outer split (#28820)
add 7da8929b60fc CAMEL-26474: camel-management - StatisticCounter: do not
update the counter with 0 (#28818)
add b72225087f91 CAMEL-26473: camel-base-engine -
AsyncProcessorAwaitManager: create the latch only when the callback is still
pending (#28817)
add a9ca7702ba76 CAMEL-26472: camel-core - Throttle EIP: do not reschedule
the clean of the throttling state on every exchange (#28816)
add fdf9c308723f CAMEL-26448: camel-core - Supervising route controller:
removing a route that is being restarted can deadlock (#28804)
add b4a5f09e93ce CAMEL-26452: camel-beanio - BeanIOSplitter keeps the
record after each record that the error handler handled (#28809)
add 47459c6eeb38 CAMEL-26468: camel-cxf-soap - fail a hanging
CxfProducerTest after 30 seconds with a thread dump (#28800)
add 442799cd9f4c CAMEL-25015: camel-core - Tokenize language: the token is
literal text unless regex is true (#28801)
add a0f6cee8324f CAMEL-25050: camel-core - variableReceive into a route or
group variable stores the header variables in that route or group (#28802)
add 7fee5aa83b7f chore(deps): Bump com.aliyun:eventbridge20200401
add 68553dd98afb chore(deps): Bump astral-sh/setup-uv from 10.3.2 to 10.3.3
add c708a31a82eb chore(camel-test-infra-aws-v2): upgrade aws.container to
2.4.0 (#28824)
add 98824c06f537 chore(deps): Bump com.auth0:java-jwt from 4.6.1 to 4.6.2
(#28841)
add da6dc5721536 chore(camel-test-infra-clickhouse): upgrade
clickhouse.container to 26.10 (#28825)
add 2c308c699adb chore(camel-test-infra-docling): upgrade
docling.container to v1.38.2 (#28826)
add c2ce976088bd chore(camel-test-infra-kafka): upgrade
redpanda.container.image to v26.2.6 (#28827)
add 5cfe19d42748 chore(camel-test-infra-kafka): upgrade
confluent.container.image to 8.4.0 (#28828)
add c8bf15beb7bd chore(camel-test-infra-milvus): upgrade milvus.container
to v2.6.26 (#28829)
add 6fe102314671 chore(camel-test-infra-ollama): upgrade ollama.container
to 0.40.13 (#28830)
add 6a7da3863410 chore(camel-test-infra-opa): upgrade opa.container to
1.22.0-static (#28831)
add 7e1ee2fa5a58 chore(camel-test-infra-openfga): upgrade
openfga.container to v1.22.1 (#28832)
add 4833e4a8f4b5 chore(camel-test-infra-pulsar): upgrade pulsar.container
to 5.0.1 (#28833)
add 8e83a4a8e561 chore(camel-test-infra-redis): upgrade redis.container to
7.4.12-alpine (#28834)
add 653925ebc94f chore(deps): Bump
org.hibernate.validator:hibernate-validator from 9.1.4.Final to 9.1.5.Final
(#28844)
add 78c9ea9e3221 chore(deps): Bump the langchain4j group with 17 updates
(#28837)
add bb546dd79ddb chore(deps): Bump aws-java-sdk2-version from 2.57.3 to
2.57.7
add 3019584ed0f0 chore(deps): Bump com.huaweicloud:esdk-obs-java from
3.26.6 to 3.26.9
add 896ff8a4bd54 CAMEL-26480: camel-jbang - sort directory file streams
for deterministic file ordering
add 25dec672fb91 chore(deps): Bump com.prowidesoftware:pw-iso20022
add 1696ae8ecf7b CAMEL-25895: docs - upgrade-guide notes for the Swift
header rename on the 4.18.6 and 4.22.3 lines (#28850)
add 50cf59774b53 CAMEL-26471: camel-util - StopWatch.taken: convert to
millis without a Duration (#28815)
add 20e4ff7c2638 CAMEL-26457: camel-disruptor - disruptor-vm queue shared
by several CamelContexts could get a second ring buffer (#28813)
add 48ea92c4092b CAMEL-26453: camel-dynamic-router - a route that sends to
a channel can be added again after it was removed (#28810)
add b2eb665ea77f CAMEL-26450: camel-telemetry - end the span of an
asynchronous step before the next step starts (#28806)
add 92c353446b56 CAMEL-26449: camel-core - DefaultShutdownStrategy: a
route stop that times out must not force or cut short the CamelContext stop
(#28805)
add 652f8c8b2b9f CAMEL-26486: camel-cassandraql - Fix flaky
CassandraKeyValueRepositoryIT
add f94c88c34bf4 CAMEL-26480: camel-jbang - follow-up improvements for
deterministic file ordering
add 8a8060b34f3b chore(deps): Bump huaweicloud-sdk-version from 3.1.221 to
3.1.222
add d1c83b567a0f chore(deps): Bump com.microsoft.onnxruntime:onnxruntime
add f4ef698232a4 chore(deps): Bump logback-version from 1.6.5 to 1.6.6
add 3ad52131a331 chore(deps): Bump com.github.ben-manes.caffeine:caffeine
add 7c80470b6c7e chore(deps): Bump mongo-java-driver-version from 5.13.0
to 5.14.0
add 6e68019c2c5a CAMEL-26481: camel-syslog - handle fragmented length
fields in Rfc5425FrameDecoder (#28846)
add d729e33c5c38 CAMEL-26456: camel-chaos - route lifecycle faults (stall
and lifecycle action=suspend|stop|remove) (#28812)
add 8f5c5ad9ff4f chore(deps): Bump dev.openfeature.contrib.providers:flagd
add c2495ef423f4 CAMEL-26482: camel-jbang - AI tools: a to: that copies
the files a file consumer moves, a placeholder left unused, and the place of an
errorHandler (#28847)
add 30afcab269af CAMEL-26483: camel-jbang - AI tools: a field of the body
a pollEnrich replaced, a variable for ${property.x}, an exception class with no
key, and no trigger note for noErrorHandler (#28848)
add 6267e9502f2a CAMEL-26489: Fix flaky ThrottlingGroupingTest
add b0501342dcdf CAMEL-26394: Fix flakiness in
SpringQuartzPersistentStoreRestartAppChangeOptionsTest
add 25ce93346f73 chore(deps): Bump com.ibm.mq:com.ibm.mq.jakarta.client
from 10.0.0.5 to 10.0.1.0 (#28852)
add 98eacfb58be3 CAMEL-26237: camel-ehcache: fix shared CacheManager, null
body handling, consumer events, and type defaults (#28822)
add ccbbcde2ea47 CAMEL-26315: Fix
TransientResumeStrategy.createSimpleCache().forEach() inverted boolean and
ConcurrentModificationException; fix KafkaResumeAdapter.resume() return value
(#28521)
add 41b262714416 CAMEL-26484: camel-jbang - AI tools: a JsonPath or SpEL
filter in Simple, a jsonpath text that is not a path, {id} for a path parameter
and json as a language are caught at write time (#28849)
add e373d74b8ccf CAMEL-26445: camel-core - RedeliveryErrorHandler: an
AsyncProcessor that throws completes the exchange instead of hanging when the
error handler has no redelivery (#28808)
add e45558b86144 CAMEL-26488: camel-mina - close the synchronous producer
session when a request times out (#28865)
add 9c2f59172db1 chore(deps): Bump
io.opentelemetry.instrumentation:opentelemetry-log4j-appender-2.17 from
2.33.0-alpha to 2.33.1-alpha (#28875)
add 024c8ec9251f chore: package-native validation - build
camel-yaml-dsl-validator from source (#28886)
add 4aec9c429a23 chore(deps): Bump com.google.errorprone:error_prone_core
add 754ce2cb1da3 chore(deps): Bump org.apache.xmlgraphics:fop from 2.11 to
2.12
add 381293125d0f chore(deps): Bump
org.springframework.vault:spring-vault-core
add 6c07f5118645 chore(deps): Bump google-cloud-functions-version from
2.87.0 to 2.88.0
add f1a7e78fbff1 chore(deps): Bump quarkus-mcp-server-version from 2.0.3
to 2.0.4
add 9a213fde6154 chore(deps): Bump djl-version from 0.39.0 to 0.40.0
add f97346b80f2c chore(deps): Bump org.duckdb:duckdb_jdbc from 1.5.6.0 to
2.0.0.0 (#28881)
add 030d45983834 CAMEL-26161: camel-zendesk - the documented syntax
zendesk:methodName fails endpoint creation (#28936)
add af6bef4113d8 CAMEL-26493: camel-jbang - AI tools: a Citrus test is
checked as YAML, not as a route, and the examples show their Citrus tests
(#28872)
add c21135a79196 CAMEL-26495: camel-jbang - camel run and camel_run do not
start a Citrus test, and say to use camel test run (#28884)
add 9af87a8bedb9 CAMEL-25973: camel-language - binary=true with a file: or
classpath: script returns the content as a stream (#28889)
add 3af4458ddef7 CAMEL-26062: camel-smooks - SAXSource, remote file, File
and Path bodies are read, exports come in a fixed order (#28890)
add 42b0c1c1e151 CAMEL-26100: camel-aws2-athena - result headers are not
taken as the input of a later operation (#28891)
add d56ad66487bc CAMEL-26069: camel-aws-bedrock - send the body as bytes,
and fail the streaming of image and embedding models (#28892)
add ac961f81d7cb CAMEL-26117: camel-debezium - the row flattened by
ExtractNewRecordState is the body, and mongodb updates expose their
updateDescription (#28893)
add 1452a4594383 CAMEL-26071: camel-aws-bedrock -
aws-bedrock-agent-runtime: invokeFlow converts the body, and the operation
header works on an endpoint of another operation (#28894)
add 0e2a286dc6de CAMEL-26118: camel-flowable - a producer created before
its channel is deployed sends once the channel is deployed, and fails with a
clear error until then (#28895)
add 3eb4c51cb6eb CAMEL-26120: camel-bonita - startCase sets the id of the
started case in a header, and a body that is not a Map fails with
InvalidPayloadException (#28897)
add 3464d84544f2 CAMEL-26121: camel-flink - use the component dataStream
options, and return a DataStream with the default collect (#28898)
add e6d529b9d3e3 CAMEL-26122: camel-spring-batch - skip null headers and
honour jobFromHeader=false (#28899)
add 0ec3f6909c26 CAMEL-26124: camel-jt400 - Fix program call without
outputFieldsIdx and with a List body (#28900)
add 8b900e03ccdf CAMEL-26125: camel-jcr - the insert operation keeps the
headers of the message (#28901)
add 1635587b1f90 CAMEL-26123: camel-optaplanner - one SolverManager per
endpoint, per-context consumers and sync events (#28902)
add 22806dff2f7b CAMEL-26127: camel-fop - accept a DOM or Source body and
fail clearly on no body (#28903)
add 41d9dd8ab401 CAMEL-26128: camel-flatpack - with splitRows each row
message has its own row, and a failing row fails the producer (#28906)
add ca69f7cf4424 CAMEL-26133: camel-robotframework - skip null body,
header, variable and property values (#28907)
add c0177a5a77a0 CAMEL-26132: camel-rss - Fail the exchange when the feed
cannot be cloned for a split entry (#28908)
add 6eec69b21a39 CAMEL-26134: camel-test-citrus - Validate byte[], file
and stream bodies by their content (#28909)
add 62c8f6e00fca CAMEL-26140: camel-undertow - send a number as text, fail
on a Map or object body, read a DELETE body, null body for a 204 (#28910)
add 958036619c28 CAMEL-26139: camel-servlet - attachmentMultipartBinding
only reads parts of multipart/form-data requests (#28912)
add 9aba86e0ad37 CAMEL-26141: camel-atmosphere-websocket - fix query
parameter without a value and the useStreaming description (#28913)
add c3ce839be05f CAMEL-26136: camel-netty - convert replies for the
default codec, fail on useByteBuf, ignore replies with sync=false (#28914)
add 1ec55622dbb4 CAMEL-26142: camel-spring-ws - null reply body, non-XML
reply body, and File/InputStream producer bodies (#28915)
add 7a48feff33a3 CAMEL-26145: camel-mybatis - Keep the body with InOut,
and fail an Insert, Update or Delete without a body when the statement has
parameters (#28916)
add 137d447a68b1 CAMEL-26146: camel-jooq - fail on an empty body and drop
the CONSUME operation from the catalog (#28917)
add f345ef6a17a6 CAMEL-26148: camel-sql - sql and sql-stored batch update
count and single Map body (#28918)
add c09c01f957f9 CAMEL-26149: camel-duckdb - document the query option
precedence, hint at the operation on a wrong statement kind, and accept a Path
or bytes body for copy (#28919)
add cf6980d06db0 CAMEL-26143: camel-cxf - fix byte[] reply, POJO parameter
splitting and bodies sent as empty messages (#28920)
add e6433f423187 CAMEL-26151: camel-pg-replication-slot - keep the
generated exchange id and put the LSN in a header (#28921)
add a1b1c8b719b0 CAMEL-26150: camel-clickhouse - return binary query
results as byte[] and fail List inserts with a clear message (#28922)
add fe77c8e2bc3e CAMEL-26144: camel-cxfrs - reply with an unchanged
request body and send a whole List body (#28923)
add f5475dfc57c9 CAMEL-26153: camel-hivemq - fail the exchange for a body
that does not convert to byte[] instead of publishing an empty payload (#28924)
add 3f3f25513695 CAMEL-26154: camel-iggy - send binary bodies as bytes and
give the consumer body as bytes (#28927)
add 9ef0c09fffde CAMEL-26155: camel-rocketmq - waitForSendResult=false
completes the exchange synchronously, and the headers are named CamelRocketMQ
(#28933)
add 48894fe86592 CAMEL-26160: camel-servicenow - remove dead Map branch in
AbstractServiceNowProcessor.unwrap (#28935)
add 2a57a18cad45 CAMEL-26163: camel-wordpress - convert a JSON text or Map
body to a Post or User (#28939)
add 9ee1e7cfade6 CAMEL-26164: camel-whatsapp - fix webhook query parsing
and a missing HTTP method (#28940)
add 020181ed8a63 CAMEL-26158: camel-vertx - reply with a stream as a
Buffer, and with a failure when the reply has no codec (#28941)
add 9a9c07ebd051 CAMEL-26166: camel-stripe - convert bytes and stream
bodies, read the CamelStripeOperation header, no retrieve before update (#28944)
add 4afa8ead45a3 CAMEL-26168: camel-twitter - fail a direct message with
no body, list only usable timeline types (#28946)
add a5c66632bf68 CAMEL-26129: camel-dfdl - fail clearly on a null or Map
body and give parse errors a message (#28905)
add 180eebf592c7 CAMEL-26169: camel-sap-netweaver - keep the url query
string and support special characters in the credentials (#28945)
add bdffa3751f26 CAMEL-26126: camel-stax - accept a byte[], Path or DOM
Document body (#28904)
add 696f8c88aed7 CAMEL-26156: camel-pubnub - FIRE and SETSTATE with an
empty body fail without calling PubNub, and PNMessageResult converts to String
(#28928)
add f3f949af1e94 CAMEL-26159: camel-salesforce - send a Map or POJO body
as JSON, fail raw on a body it cannot send (#28942)
add 50376680fdd7 CAMEL-26165: camel-clickup - deliver webhook events of
other kinds as GenericEvent instead of failing with 500 (#28943)
add ef973877aec6 CAMEL-26499: camel-smooks - convert a remote file to a
Smooks Source, set the execution context header on a bean route with a
correlation id (#28977)
add 20a3c9d83f8e CAMEL-26498: camel-xml-jaxp - stream caching a SAXSource
without an XMLReader parses it with the secure XMLReader (#28979)
add 496f8c8bdd1b CAMEL-26500: camel-aws-bedrock - deprecate the
invokeImageModelStreaming and invokeEmbeddingsModelStreaming operations (#28980)
add 0d1d5ab0f989 CAMEL-26152: camel-sjms - fail the message when an InOut
reply cannot be sent, and support jmsMessageType=Stream (#28925)
add df4fa21ee94e CAMEL-26502: camel-bonita - startCase accepts a JSON text
body as the contract inputs (#28982)
add 9b839f3fda97 chore: camel-debezium-mongodb - docs: CamelDebeziumBefore
is set with the pre-image capture modes (#28978)
add eab9a0ca3b62 chore: camel-rss - do not log a WARN when the feed cannot
be cloned (#28983)
add 8561a9b1ca3d CAMEL-26503: camel-platform-http-vertx - write a number,
boolean, character or enum reply as text (#28984)
add c4762905ce91 chore: camel-clickhouse - treat an empty List body as a
0-row insert (#28986)
add f02b49e1a7c3 chore: camel-zendesk - fix the environment variable names
of the integration test setup (#28988)
add b05201d85057 CAMEL-26119: camel-camunda - read a JSON body as bytes or
a stream, and fail the exchange when an operation fails; the JSON uses
camelCase (#28896)
add 7c13a878cbb4 CAMEL-26220: camel-ibm-watson-discovery - manage
com.ibm.cloud:sdk-core 9.24.3, which works with the Gson of Camel, so query no
longer fails with NoClassDefFoundError for $Gson$Types (#28974)
add 869ea9ad41c0 CAMEL-26223: camel-ibm-watson-speech-to-text - close the
audio stream opened for a File, Path or file consumer body (#28972)
add 8d8976c88250 CAMEL-26222: camel-ibm-watsonx-ai - check the elements of
a List of chat messages, and read a bytes or stream body as text for chat,
embedding and rerank (#28971)
add 70e52ddde700 CAMEL-26268: camel-huaweicloud-obs - putObject needs the
bucket name for a File body too (#28967)
add a72119122ec1 CAMEL-26266: camel-huaweicloud-functiongraph - keep the
whole result when it has no body field, and take a JSON object event as bytes,
a stream or a file (#28965)
add 9f59b88c810f CAMEL-26253: camel-google-secret-manager - createSecret
reads the value before it creates the secret, and takes a CreateSecretRequest
with pojoRequest=true (#28963)
add 98d83cd974de CAMEL-26299: camel-azure-eventgrid - build the CloudEvent
with the data format of the body, so sending no longer fails with a
NullPointerException (#28957)
add 421579fe25f9 CAMEL-26262: camel-alibaba-sls - the putLogs examples
build a LogGroup with a bean instead of setting a text body (#28953)
add 7292654a06e9 CAMEL-26260: camel-alibaba-eventbridge - a byte[], stream
or file body is read as the JSON text of the event, instead of failing (#28951)
add 9ff19010c52c CAMEL-26258: camel-alibaba-kms - encrypt encrypts a
stream or a file as its bytes, so binary plaintext is not corrupted (#28949)
add 52c3e9428891 CAMEL-26257: camel-alibaba-fc - invokeFunction sends a
stream or a file as its bytes, so binary data is not corrupted (#28948)
add 88e4b8603214 chore(deps): Bump io.qdrant:client from 1.19.0 to 1.20.0
(#28938)
add 1d2c682d736c chore(deps): Bump web3j-version from 6.0.0 to 6.1.0
(#28937)
add 8bbf76c5b0c1 chore(deps): Bump io.rest-assured:rest-assured from 6.2.0
to 6.3.0 (#28934)
add 59b40d558335 chore(deps-dev): Bump com.icegreen:greenmail from 2.1.14
to 2.1.15 (#28932)
add c90d761ee127 chore(deps): Bump io.camunda:camunda-client-java from
8.10.4 to 8.10.7 (#28930)
add 262ef0d74e82 chore(deps): Bump quarkus-version from 3.40.1 to 3.40.1.1
(#28929)
add 41f7da961d17 CAMEL-26251: camel-google-bigquery - endpoints use the
connectionFactory of the component, a DDL statement gives no body instead of a
NullPointerException, and a body that is not a row fails a grouped exchange
before any row is inserted (#28970)
add b4d63b7d7206 CAMEL-26269: camel-huaweicloud-smn - publish a Map, a
List or a POJO as JSON, and set the message id in CamelHwCloudSmnMessageId
(#28968)
add 4d6de5df2521 CAMEL-26138: camel-http-common - write a chunked or gzip
Map, List, POJO or number reply, keep a form POST body with
disableStreamCache=true, and mapHttpMessageBody=false leaves the body null
(#28911)
add ac892fc4de6b CAMEL-26243: camel-google-sheets - remove
spreadsheets/developerMetadata, sheets and values, the accessors of
sub-resources that failed with a ClassCastException, and document that
splitResult has no effect (#28959)
add acb8f1cfb325 CAMEL-26242: camel-google-mail - remove
messages/attachments, the accessor of the Attachments sub-resource, which
failed with a ClassCastException (#28958)
add f6e08d43062a CAMEL-26247: camel-azure-functions - send the body as
bytes, add the default Content-Type without the headers map, and fail on an
HTTP error status (#28955)
add 2883080b73c9 CAMEL-26261: camel-alibaba-oss - add the includeBody
option, so the consumer can give the stream of an object instead of reading it
into a byte array (#28952)
add 1743bcb5f98f CAMEL-26259: camel-alibaba-mns - send a byte[], stream or
file body as its bytes, give a binary message as bytes, set the message id and
MD5 as headers, and drop receiveMessage from the operations (#28950)
add 6bf110ff054f CAMEL-26252: camel-google-functions - a failed
callFunction fails the exchange, no body fails with an InvalidPayloadException,
and a Map or POJO body is sent as JSON (#28962)
add 9d9c2e836a13 CAMEL-26432: camel-chaos - error status= for netty-http
(#28811)
add d00414c78996 CAMEL-26250: camel-google-vertexai - generateMultimodal
sends a stream, file or bytes body as media, rawPredict reads bytes, stream and
file bodies as text, and the declared headers are applied or deprecated (#28969)
add 4861336aaf4f CAMEL-26267: camel-huaweicloud-iam - read the JSON of
updateUser and updateGroup from bytes, a stream or a file, and write the
results with the field names of the IAM API (#28966)
add f10e145d3b1e CAMEL-26265: camel-huaweicloud-dms - read the JSON
request from bytes, a stream or a file, and fail on a body that is not the
request (#28964)
add 81d06027f606 CAMEL-26249: camel-google-text-to-speech -
pojoRequest=true runs the operation, and listVoices lists all voices unless
languageCode is set (#28961)
add 403acb0ca8c1 CAMEL-26505: camel-jms / camel-sjms - a body that maps to
no JMS message type fails the exchange instead of being sent as an empty
message (#28987)
add d86e316b04a9 CAMEL-26244: camel-google-drive - drive-files/export, and
drive-files/get and drive-revisions/get with alt=media, give the content of the
file as an InputStream, and FileConverterIT uses drive-files/create (#28960)
add e9b27ef1d7b3 CAMEL-26507: camel-vertx - the producer sends a message
without a body as a null body (#28989)
add 07f5c40033ca CAMEL-26504: camel-netty / camel-netty-http - answer or
close when the reply cannot be built or written, honour allowSerializedHeaders
on the reply (#28985)
add 94e7619f147d chore: camel-launcher - run the distribution ITs in
verify, not with -Dquickly, and in the native exe workflow (#28885)
add e4dc3321370c CAMEL-25674: camel-netty-http - hostnameVerification no
longer breaks client certificates on a consumer (#28871)
add b59a37efd89c CAMEL-26490: camel-telemetry, camel-tracing - present the
http.url, url.path and server.address span attributes like camel.uri (#28867)
add 4496b464aa1c Merge remote-tracking branch 'origin/main' into
CAMEL-26298-mcp-stdio-startup
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 3 +
.github/workflows/camel-launcher-native-exe.yml | 5 +-
.github/workflows/package-native-validation.yml | 8 +-
.github/workflows/pr-ci-scripts-validation.yml | 2 +-
.../catalog/components/alibaba-eventbridge.json | 2 +-
.../camel/catalog/components/alibaba-fc.json | 2 +-
.../camel/catalog/components/alibaba-kms.json | 2 +-
.../camel/catalog/components/alibaba-mns.json | 8 +-
.../camel/catalog/components/alibaba-oss.json | 59 +-
.../catalog/components/atmosphere-websocket.json | 4 +-
.../components/aws-bedrock-agent-runtime.json | 12 +-
.../camel/catalog/components/aws-bedrock.json | 16 +-
.../camel/catalog/components/azure-eventgrid.json | 2 +-
.../camel/catalog/components/azure-functions.json | 50 +-
.../apache/camel/catalog/components/bonita.json | 7 +-
.../apache/camel/catalog/components/camunda.json | 4 +-
.../apache/camel/catalog/components/citrus.json | 2 +-
.../camel/catalog/components/clickhouse.json | 4 +-
.../apache/camel/catalog/components/clickup.json | 2 +-
.../org/apache/camel/catalog/components/cxf.json | 4 +-
.../org/apache/camel/catalog/components/cxfrs.json | 4 +-
.../camel/catalog/components/debezium-mongodb.json | 5 +-
.../apache/camel/catalog/components/duckdb.json | 6 +-
.../apache/camel/catalog/components/flatpack.json | 4 +-
.../org/apache/camel/catalog/components/flink.json | 4 +-
.../org/apache/camel/catalog/components/fop.json | 2 +-
.../catalog/components/google-bigquery-sql.json | 2 +-
.../camel/catalog/components/google-bigquery.json | 2 +-
.../camel/catalog/components/google-drive.json | 9 +-
.../camel/catalog/components/google-functions.json | 4 +-
.../camel/catalog/components/google-mail.json | 6 +-
.../catalog/components/google-secret-manager.json | 4 +-
.../camel/catalog/components/google-sheets.json | 8 +-
.../catalog/components/google-text-to-speech.json | 6 +-
.../camel/catalog/components/google-vertexai.json | 16 +-
.../apache/camel/catalog/components/hivemq.json | 2 +-
.../camel/catalog/components/hwcloud-dms.json | 2 +-
.../catalog/components/hwcloud-functiongraph.json | 4 +-
.../camel/catalog/components/hwcloud-iam.json | 4 +-
.../camel/catalog/components/hwcloud-smn.json | 4 +-
.../camel/catalog/components/ibm-watsonx-ai.json | 2 +-
.../org/apache/camel/catalog/components/iggy.json | 15 +-
.../org/apache/camel/catalog/components/jetty.json | 2 +-
.../org/apache/camel/catalog/components/jooq.json | 4 +-
.../org/apache/camel/catalog/components/jt400.json | 2 +-
.../camel/catalog/components/optaplanner.json | 4 +-
.../catalog/components/pg-replication-slot.json | 5 +-
.../apache/camel/catalog/components/pubnub.json | 2 +-
.../camel/catalog/components/robotframework.json | 2 +-
.../apache/camel/catalog/components/rocketmq.json | 44 +-
.../camel/catalog/components/salesforce.json | 6 +-
.../apache/camel/catalog/components/servlet.json | 2 +-
.../org/apache/camel/catalog/components/sjms.json | 2 +-
.../org/apache/camel/catalog/components/sjms2.json | 2 +-
.../camel/catalog/components/spring-batch.json | 4 +-
.../camel/catalog/components/sql-stored.json | 6 +-
.../org/apache/camel/catalog/components/sql.json | 4 +-
.../org/apache/camel/catalog/components/stax.json | 2 +-
.../apache/camel/catalog/components/stripe.json | 4 +-
.../catalog/components/twitter-directmessage.json | 2 +-
.../camel/catalog/components/twitter-timeline.json | 2 +-
.../org/apache/camel/catalog/components/vertx.json | 8 +-
.../apache/camel/catalog/components/wordpress.json | 2 +-
.../apache/camel/catalog/dev-consoles-openapi.json | 103 +++
.../apache/camel/catalog/dev-consoles.properties | 1 +
.../apache/camel/catalog/dev-consoles/chaos.json | 103 +++
.../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 | 12 +-
.../camel/catalog/docs/aws-bedrock-component.adoc | 32 +-
.../camel/catalog/docs/aws2-athena-component.adoc | 15 +-
.../catalog/docs/azure-eventgrid-component.adoc | 16 +
.../catalog/docs/azure-functions-component.adoc | 17 +
.../camel/catalog/docs/bonita-component.adoc | 7 +-
.../camel/catalog/docs/camunda-component.adoc | 41 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 179 ++++-
.../camel/catalog/docs/citrus-component.adoc | 10 +
.../camel/catalog/docs/clickhouse-component.adoc | 14 +-
.../camel/catalog/docs/clickup-component.adoc | 6 +
.../apache/camel/catalog/docs/cxf-component.adoc | 7 +
.../apache/camel/catalog/docs/cxfrs-component.adoc | 11 +-
.../camel/catalog/docs/debezium-db2-component.adoc | 6 +
.../catalog/docs/debezium-mongodb-component.adoc | 19 +-
.../catalog/docs/debezium-mysql-component.adoc | 6 +
.../catalog/docs/debezium-oracle-component.adoc | 6 +
.../catalog/docs/debezium-postgres-component.adoc | 6 +
.../catalog/docs/debezium-sqlserver-component.adoc | 6 +
.../camel/catalog/docs/duckdb-component.adoc | 10 +-
.../camel/catalog/docs/ehcache-component.adoc | 16 +-
.../camel/catalog/docs/flatpack-component.adoc | 12 +-
.../apache/camel/catalog/docs/flink-component.adoc | 3 +-
.../camel/catalog/docs/flowable-component.adoc | 8 +-
.../catalog/docs/google-bigquery-component.adoc | 4 +
.../docs/google-bigquery-sql-component.adoc | 1 +
.../camel/catalog/docs/google-drive-component.adoc | 69 ++
.../catalog/docs/google-functions-component.adoc | 12 +
.../docs/google-secret-manager-component.adoc | 40 +-
.../catalog/docs/google-sheets-component.adoc | 9 +
.../docs/google-text-to-speech-component.adoc | 32 +-
.../catalog/docs/google-vertexai-component.adoc | 74 +-
.../camel/catalog/docs/hivemq-component.adoc | 4 +
.../camel/catalog/docs/hwcloud-dms-component.adoc | 6 +-
.../docs/hwcloud-functiongraph-component.adoc | 15 +
.../camel/catalog/docs/hwcloud-iam-component.adoc | 31 +-
.../camel/catalog/docs/hwcloud-smn-component.adoc | 13 +-
.../docs/ibm-watson-speech-to-text-component.adoc | 7 +
.../catalog/docs/ibm-watsonx-ai-component.adoc | 13 +
.../apache/camel/catalog/docs/iggy-component.adoc | 24 +-
.../apache/camel/catalog/docs/jms-component.adoc | 8 +
.../apache/camel/catalog/docs/jooq-component.adoc | 3 +
.../apache/camel/catalog/docs/jt400-component.adoc | 8 +-
.../camel/catalog/docs/language-component.adoc | 44 ++
.../camel/catalog/docs/mybatis-component.adoc | 6 +
.../apache/camel/catalog/docs/netty-component.adoc | 10 +
.../camel/catalog/docs/netty-http-component.adoc | 11 +
.../camel/catalog/docs/optaplanner-component.adoc | 12 +-
.../docs/pg-replication-slot-component.adoc | 3 +
.../camel/catalog/docs/platform-http-vertx.adoc | 7 +
.../camel/catalog/docs/pubnub-component.adoc | 3 +
.../catalog/docs/robotframework-component.adoc | 24 +-
.../camel/catalog/docs/rocketmq-component.adoc | 20 +-
.../apache/camel/catalog/docs/rss-component.adoc | 5 +
.../camel/catalog/docs/salesforce-component.adoc | 2 +-
.../camel/catalog/docs/salesforce-rest-api.adoc | 3 +
.../apache/camel/catalog/docs/sjms-component.adoc | 8 +-
.../apache/camel/catalog/docs/sjms2-component.adoc | 8 +-
.../camel/catalog/docs/smooks-component.adoc | 4 +-
.../camel/catalog/docs/spring-batch-component.adoc | 8 +-
.../camel/catalog/docs/spring-ws-component.adoc | 8 +
.../apache/camel/catalog/docs/sql-component.adoc | 4 +
.../camel/catalog/docs/sql-stored-component.adoc | 18 +
.../apache/camel/catalog/docs/stax-component.adoc | 1 +
.../camel/catalog/docs/stripe-component.adoc | 9 +-
.../camel/catalog/docs/tokenize-language.adoc | 5 +
.../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 +-
.../apache/camel/catalog/test-infra/metadata.json | 52 +-
.../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 | 12 +-
.../src/main/docs/aws-bedrock-component.adoc | 32 +-
.../BedrockAgentRuntimeConfiguration.java | 6 +-
.../agentruntime/BedrockAgentRuntimeConstants.java | 2 +-
.../agentruntime/BedrockAgentRuntimeEndpoint.java | 37 +-
.../agentruntime/BedrockAgentRuntimeProducer.java | 51 +-
.../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 | 149 +++-
.../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 +
.../BedrockAgentRuntimeProducerInvokeFlowTest.java | 35 +
.../BedrockAgentRuntimeProducerOperationTest.java | 146 ++++
...BedrockInvokeTextModelUnsupportedModelTest.java | 1 +
.../runtime/BedrockProducerRequestTest.java | 431 +++++++++++
.../runtime/stream/ConverseStreamHandlerTest.java | 43 ++
.../src/main/docs/aws2-athena-component.adoc | 15 +-
.../component/aws2/athena/Athena2Producer.java | 97 ++-
.../athena/Athena2ProducerResultHeadersTest.java | 253 +++++++
.../aws2/kinesis/KinesisConsumerPositionTest.java | 7 +-
.../component/azure/eventgrid/azure-eventgrid.json | 2 +-
.../src/main/docs/azure-eventgrid-component.adoc | 16 +
.../azure/eventgrid/EventGridEndpoint.java | 14 +-
.../azure/eventgrid/EventGridProducer.java | 87 ++-
.../azure/eventgrid/EventGridProducerTest.java | 294 ++++++++
.../camel-azure/camel-azure-functions/pom.xml | 5 +
.../functions/FunctionsComponentConfigurer.java | 6 +
.../functions/FunctionsEndpointConfigurer.java | 6 +
.../functions/FunctionsEndpointUriFactory.java | 3 +-
.../component/azure/functions/azure-functions.json | 50 +-
.../src/main/docs/azure-functions-component.adoc | 17 +
.../azure/functions/FunctionsConfiguration.java | 14 +
.../azure/functions/FunctionsEndpoint.java | 24 +-
.../azure/functions/FunctionsProducer.java | 43 +-
.../client/FunctionsInvocationClient.java | 36 +-
.../functions/FunctionsProducerInvokeTest.java | 316 ++++++++
.../camel/dataformat/beanio/BeanIOIterator.java | 64 +-
.../camel/dataformat/beanio/BeanIOSplitter.java | 15 +-
...IOSplitterCustomBeanReaderErrorHandlerTest.java | 105 +++
components/camel-bonita/pom.xml | 4 +
.../org/apache/camel/component/bonita/bonita.json | 7 +-
.../src/main/docs/bonita-component.adoc | 7 +-
.../camel/component/bonita/BonitaConstants.java} | 16 +-
.../camel/component/bonita/BonitaEndpoint.java | 15 +-
.../bonita/producer/BonitaStartProducer.java | 45 +-
.../component/bonita/BonitaStartProducerTest.java | 212 ++++++
.../apache/camel/component/camunda/camunda.json | 4 +-
.../src/main/docs/camunda-component.adoc | 41 +-
.../camel/component/camunda/CamundaEndpoint.java | 14 +-
.../camunda/model/AbstractCamundaResponse.java | 4 -
.../component/camunda/model/DeploymentRequest.java | 2 -
.../camel/component/camunda/model/JobRequest.java | 8 +-
.../component/camunda/model/MessageRequest.java | 4 -
.../component/camunda/model/MessageResponse.java | 3 -
.../camunda/model/ProcessDeploymentResponse.java | 4 -
.../component/camunda/model/ProcessRequest.java | 5 -
.../component/camunda/model/ProcessResponse.java | 5 -
.../camunda/processor/AbstractBaseProcessor.java | 31 +
.../camunda/processor/DeploymentProcessor.java | 1 +
.../component/camunda/processor/JobProcessor.java | 29 +-
.../camunda/processor/MessageProcessor.java | 19 +-
.../camunda/processor/ProcessProcessor.java | 31 +-
.../component/camunda/CamundaProducerTest.java | 301 ++++++++
.../cassandra/CassandraKeyValueRepositoryIT.java | 195 ++---
components/camel-chaos/pom.xml | 11 +
.../org/apache/camel/dev-console/chaos.json | 103 +++
.../services/org/apache/camel/dev-console/chaos | 2 +
.../org/apache/camel/dev-consoles.properties | 7 +
components/camel-chaos/src/main/docs/chaos.adoc | 179 ++++-
.../component/chaos/ChaosContextServicePlugin.java | 34 +-
.../camel/component/chaos/ChaosDevConsole.java | 98 +++
.../apache/camel/component/chaos/ChaosFaults.java | 58 +-
.../camel/component/chaos/ChaosLifecycle.java | 583 +++++++++++++++
.../apache/camel/component/chaos/ChaosManager.java | 76 +-
.../camel/component/chaos/ChaosPatterns.java | 27 +
.../camel/component/chaos/ChaosPollStrategy.java | 3 +-
.../apache/camel/component/chaos/ChaosReport.java | 129 +++-
.../apache/camel/component/chaos/ChaosRule.java | 59 +-
.../camel/component/chaos/ChaosRuleParser.java | 144 +++-
.../camel/component/chaos/ChaosSendHook.java | 3 +-
.../camel/component/chaos/ChaosActivationTest.java | 30 +
.../camel/component/chaos/ChaosDevConsoleTest.java | 205 ++++++
.../camel/component/chaos/ChaosHttpFaultTest.java | 15 +-
.../component/chaos/ChaosLifecycleStartupTest.java | 186 +++++
.../camel/component/chaos/ChaosLifecycleTest.java | 459 ++++++++++++
.../component/chaos/ChaosNettyHttpFaultTest.java | 235 ++++++
.../camel/component/chaos/ChaosReportTest.java | 2 +-
.../camel/component/chaos/ChaosRuleParserTest.java | 92 ++-
.../camel/component/chaos/TestHttpComponent.java | 21 +-
.../camel/component/clickhouse/clickhouse.json | 4 +-
.../src/main/docs/clickhouse-component.adoc | 14 +-
.../component/clickhouse/ClickHouseConstants.java | 4 +-
.../component/clickhouse/ClickHouseEndpoint.java | 13 +-
.../component/clickhouse/ClickHouseProducer.java | 59 +-
.../clickhouse/ClickHouseProducerTest.java | 87 ++-
.../integration/ClickHouseProducerIT.java | 42 ++
.../apache/camel/component/clickup/clickup.json | 2 +-
.../src/main/docs/clickup-component.adoc | 6 +
.../camel/component/clickup/ClickUpEndpoint.java | 9 +-
.../camel/component/clickup/model/Event.java | 15 +-
.../component/clickup/model/GenericEvent.java | 60 ++
.../component/clickup/ClickUpWebhookCallTest.java | 41 ++
.../resources/messages/events/task-created.json | 38 +
.../apache/camel/component/cxf/jaxrs/cxfrs.json | 4 +-
.../src/main/docs/cxfrs-component.adoc | 11 +-
.../camel/component/cxf/jaxrs/CxfRsEndpoint.java | 12 +-
.../component/cxf/jaxrs/DefaultCxfRsBinding.java | 40 +-
.../component/cxf/jaxrs/SimpleCxfRsBinding.java | 3 +-
.../cxf/jaxrs/CxfRsConsumerUnchangedBodyTest.java | 99 +++
.../cxf/jaxrs/DefaultCxfRsBindingTest.java | 89 +++
.../org/apache/camel/component/cxf/jaxws/cxf.json | 4 +-
.../src/main/docs/cxf-component.adoc | 7 +
.../camel/component/cxf/jaxws/CxfEndpoint.java | 37 +-
.../camel/component/cxf/jaxws/CxfProducer.java | 25 +-
.../component/cxf/jaxws/DefaultCxfBinding.java | 43 +-
.../component/cxf/jaxws/BodyTypeService.java} | 21 +-
.../component/cxf/jaxws/CxfBodyTypesTest.java | 174 +++++
.../camel/component/cxf/jaxws/CxfProducerTest.java | 9 +
.../src/test/resources/junit-platform.properties | 5 +-
.../component/debezium/DebeziumConstants.java | 5 +
.../camel/component/debezium/DebeziumEndpoint.java | 38 +-
.../component/debezium/DebeziumTypeConverter.java | 34 +-
.../component/debezium/DebeziumEndpointTest.java | 95 ++-
.../debezium/DebeziumTypeConverterTest.java | 27 +
.../src/main/docs/debezium-db2-component.adoc | 6 +
.../debezium/mongodb/debezium-mongodb.json | 5 +-
.../src/main/docs/debezium-mongodb-component.adoc | 19 +-
.../debezium/mongodb/DebeziumMongodbEndpoint.java | 28 +-
.../mongodb/DebeziumMongodbEndpointTest.java | 125 ++++
.../src/main/docs/debezium-mysql-component.adoc | 6 +
.../src/main/docs/debezium-oracle-component.adoc | 6 +
.../src/main/docs/debezium-postgres-component.adoc | 6 +
.../main/docs/debezium-sqlserver-component.adoc | 6 +
.../apache/camel/component/dfdl/DfdlEndpoint.java | 4 +-
.../camel/component/dfdl/DfdlParseException.java | 22 +
.../camel/component/dfdl/DfdlUnparseException.java | 1 +
.../camel/dataformat/dfdl/DfdlDataFormat.java | 5 +-
.../camel/component/dfdl/DfdlComponentTest.java | 40 +-
.../camel/dataformat/dfdl/DfdlDataFormatTest.java | 57 +-
.../component/disruptor/DisruptorComponent.java | 76 +-
.../component/disruptor/DisruptorEndpoint.java | 16 +-
.../component/disruptor/DisruptorReference.java | 45 ++
.../disruptor/vm/DisruptorVmComponent.java | 40 +-
.../DisruptorVmSharedQueueReferenceTest.java | 438 +++++++++++
.../vm/DisruptorVmComponentStartCounterTest.java | 53 ++
.../org/apache/camel/component/duckdb/duckdb.json | 6 +-
.../src/main/docs/duckdb-component.adoc | 10 +-
.../camel/component/duckdb/DuckDbConstants.java | 4 +-
.../camel/component/duckdb/DuckDbEndpoint.java | 8 +-
.../camel/component/duckdb/DuckDbProducer.java | 31 +-
.../camel/component/duckdb/DuckDbProducerTest.java | 98 +++
.../routing/DynamicRouterComponent.java | 90 ++-
.../routing/DynamicRouterEndpoint.java | 46 +-
.../routing/DynamicRouterProcessor.java | 18 +
.../routing/DynamicRouterProducer.java | 27 +-
.../routing/DynamicRouterComponentTest.java | 55 +-
.../routing/DynamicRouterProducerTest.java | 20 +
.../routing/DynamicRouterRemoveRouteTest.java | 275 +++++++
.../src/main/docs/ehcache-component.adoc | 16 +-
.../camel/component/ehcache/EhcacheComponent.java | 5 +-
.../camel/component/ehcache/EhcacheConsumer.java | 2 +-
.../camel/component/ehcache/EhcacheManager.java | 95 ++-
.../camel/component/ehcache/EhcacheProducer.java | 4 +-
.../ehcache/EhcacheCacheConfigurationTest.java | 4 +-
.../component/ehcache/EhcacheDefaultsTest.java | 207 ++++++
.../component/ehcache/EhcacheRemoveRouteTest.java | 77 +-
.../apache/camel/component/flatpack/flatpack.json | 4 +-
.../src/main/docs/flatpack-component.adoc | 12 +-
.../camel/component/flatpack/DataSetRow.java | 343 +++++++++
.../component/flatpack/FlatpackConverter.java | 4 +
.../camel/component/flatpack/FlatpackEndpoint.java | 32 +-
.../camel/component/flatpack/FlatpackProducer.java | 6 +-
.../component/flatpack/FlatpackSplitRowsTest.java | 201 +++++
.../org/apache/camel/component/flink/flink.json | 4 +-
.../camel-flink/src/main/docs/flink-component.adoc | 3 +-
.../component/flink/DataStreamFlinkProducer.java | 6 +-
.../camel/component/flink/FlinkEndpoint.java | 27 +-
.../DataStreamComponentOptionsAndCollectTest.java | 87 +++
.../src/main/docs/flowable-component.adoc | 8 +-
.../camel/component/flowable/FlowableEndpoint.java | 8 +
.../camel/component/flowable/FlowableProducer.java | 26 +-
.../FlowableProducerChannelNotDeployedTest.java | 85 +++
.../resources/channel/userRouteChannel.channel | 10 +
.../org/apache/camel/component/fop/fop.json | 2 +-
.../apache/camel/component/fop/FopEndpoint.java | 7 +-
.../apache/camel/component/fop/FopProducer.java | 18 +-
.../apache/camel/component/fop/FopBodyTest.java | 93 +++
.../component/google/bigquery/google-bigquery.json | 2 +-
.../google/bigquery/sql/google-bigquery-sql.json | 2 +-
.../src/main/docs/google-bigquery-component.adoc | 4 +
.../main/docs/google-bigquery-sql-component.adoc | 1 +
.../google/bigquery/GoogleBigQueryComponent.java | 4 +
.../google/bigquery/GoogleBigQueryEndpoint.java | 7 +-
.../google/bigquery/GoogleBigQueryProducer.java | 80 +-
.../bigquery/sql/GoogleBigQuerySQLComponent.java | 4 +
.../bigquery/sql/GoogleBigQuerySQLEndpoint.java | 8 +-
.../bigquery/sql/GoogleBigQuerySQLProducer.java | 7 +-
...ogleBigQueryComponentConnectionFactoryTest.java | 110 +++
.../unit/GoogleBigQueryProducerBodyTypeTest.java | 105 ++-
.../GoogleBigQuerySQLProducerStatementTest.java | 61 ++
.../camel/component/google/drive/google-drive.json | 9 +-
.../src/main/docs/google-drive-component.adoc | 69 ++
.../google/drive/GoogleDriveConfiguration.java | 2 +-
.../google/drive/GoogleDriveConsumer.java | 22 +-
.../google/drive/GoogleDriveEndpoint.java | 25 +-
.../google/drive/GoogleDriveProducer.java | 7 +-
.../google/drive/GoogleDriveRequestHelper.java | 54 ++
.../drive/internal/GoogleDriveConstants.java | 8 +-
.../component/google/drive/FileConverterIT.java | 13 +-
.../google/drive/GoogleDriveApiMethodsTest.java | 48 ++
.../google/drive/GoogleDriveMediaContentTest.java | 229 ++++++
.../camel-google/camel-google-functions/pom.xml | 5 +
.../google/functions/google-functions.json | 4 +-
.../src/main/docs/google-functions-component.adoc | 12 +
.../functions/GoogleCloudFunctionsEndpoint.java | 23 +-
.../functions/GoogleCloudFunctionsProducer.java | 67 +-
.../unit/GoogleCloudFunctionsCallFunctionTest.java | 275 +++++++
.../unit/GoogleCloudFunctionsComponentTest.java | 4 +-
components/camel-google/camel-google-mail/pom.xml | 3 +
.../GmailUsersMessagesEndpointConfiguration.java | 4 +-
.../mail/internal/GmailUsersMessagesApiMethod.java | 4 -
.../camel/component/google/mail/google-mail.json | 6 +-
.../google/mail/GoogleMailConfiguration.java | 2 +-
.../google/mail/GmailUsersMessagesIT.java | 3 -
.../google/mail/GoogleMailApiMethodsTest.java | 114 +++
.../secret/manager/google-secret-manager.json | 4 +-
.../main/docs/google-secret-manager-component.adoc | 40 +-
.../manager/GoogleSecretManagerEndpoint.java | 20 +-
.../manager/GoogleSecretManagerProducer.java | 27 +-
.../unit/GoogleSecretManagerCreateSecretTest.java | 168 +++++
.../camel-google/camel-google-sheets/pom.xml | 3 +
.../SheetsSpreadsheetsEndpointConfiguration.java | 2 +-
.../internal/SheetsSpreadsheetsApiMethod.java | 14 +-
.../component/google/sheets/google-sheets.json | 8 +-
.../src/main/docs/google-sheets-component.adoc | 9 +
.../google/sheets/GoogleSheetsConfiguration.java | 2 +-
.../google/sheets/GoogleSheetsEndpoint.java | 4 +-
.../google/sheets/GoogleSheetsApiMethodsTest.java | 114 +++
.../GoogleSheetsConsumerSplitResultTest.java | 37 +
.../google/texttospeech/google-text-to-speech.json | 6 +-
.../main/docs/google-text-to-speech-component.adoc | 32 +-
.../GoogleCloudTextToSpeechConfiguration.java | 13 +-
.../GoogleCloudTextToSpeechEndpoint.java | 16 +-
.../GoogleCloudTextToSpeechProducer.java | 48 +-
.../unit/GoogleCloudTextToSpeechProducerTest.java | 210 ++++++
.../component/google/vertexai/google-vertexai.json | 16 +-
.../src/main/docs/google-vertexai-component.adoc | 74 +-
.../google/vertexai/GoogleVertexAIConstants.java | 33 +-
.../google/vertexai/GoogleVertexAIEndpoint.java | 34 +-
.../google/vertexai/GoogleVertexAIProducer.java | 210 ++++--
.../vertexai/GoogleVertexAIProducerBodyTest.java | 605 +++++++++++++++
.../GoogleVertexAIProducerOptionsTest.java | 36 +
.../org/apache/camel/component/hivemq/hivemq.json | 2 +-
.../src/main/docs/hivemq-component.adoc | 4 +
.../camel/component/hivemq/HiveMQEndpoint.java | 3 +-
.../camel/component/hivemq/HiveMQProducer.java | 27 +-
.../component/hivemq/HiveMQProducerBodyTest.java | 187 +++++
.../camel/http/common/DefaultHttpBinding.java | 55 +-
.../org/apache/camel/http/common/HttpBinding.java | 3 +-
.../camel/http/common/HttpCommonEndpoint.java | 9 +-
.../org/apache/camel/http/common/HttpMessage.java | 4 +
.../http/common/DefaultHttpBindingGzipTest.java | 122 ++++
.../component/huaweicloud/dms/hwcloud-dms.json | 2 +-
.../src/main/docs/hwcloud-dms-component.adoc | 6 +-
.../component/huaweicloud/dms/DMSEndpoint.java | 16 +-
.../component/huaweicloud/dms/DMSProducer.java | 122 +++-
.../huaweicloud/dms/CreateInstanceKafka1Test.java | 2 +-
.../huaweicloud/dms/CreateInstanceKafka2Test.java | 2 +-
.../dms/CreateInstanceMissingStorageSpaceTest.java | 2 +-
.../huaweicloud/dms/CreateInstanceRmq1Test.java | 2 +-
.../huaweicloud/dms/CreateInstanceRmq2Test.java | 2 +-
.../huaweicloud/dms/InstanceRequestBodyTest.java | 359 +++++++++
.../org/apache/camel/hwcloud-functiongraph.json | 4 +-
.../main/docs/hwcloud-functiongraph-component.adoc | 15 +
.../org/apache/camel/FunctionGraphEndpoint.java | 20 +-
.../org/apache/camel/FunctionGraphProducer.java | 72 +-
.../java/org/apache/camel/FunctionGraphUtils.java | 38 +-
.../org/apache/camel/InvokeFunctionBodyTest.java | 234 ++++++
.../camel-huawei/camel-huaweicloud-iam/pom.xml | 5 -
.../component/huaweicloud/iam/hwcloud-iam.json | 4 +-
.../src/main/docs/hwcloud-iam-component.adoc | 31 +-
.../component/huaweicloud/iam/IAMEndpoint.java | 18 +-
.../component/huaweicloud/iam/IAMProducer.java | 141 +++-
.../component/huaweicloud/iam/GetUserTest.java | 2 +-
.../huaweicloud/iam/IAMProducerJsonTest.java | 371 ++++++++++
.../component/huaweicloud/iam/ListUsersTest.java | 2 +-
.../huaweicloud/iam/UpdateGroupJsonTest.java | 2 +-
.../component/huaweicloud/iam/UpdateGroupTest.java | 2 +-
.../component/huaweicloud/obs/OBSProducer.java | 11 +-
.../obs/PutObjectMandatoryNamesTest.java | 153 ++++
.../component/huaweicloud/smn/hwcloud-smn.json | 4 +-
.../src/main/docs/hwcloud-smn-component.adoc | 13 +-
.../smn/SimpleNotificationEndpoint.java | 18 +-
.../smn/SimpleNotificationProducer.java | 70 +-
.../huaweicloud/smn/constants/SmnProperties.java | 10 +
.../huaweicloud/smn/PublishMessageBodyTest.java | 260 +++++++
.../smn/PublishTemplatedMessageFunctionalTest.java | 4 +-
.../smn/PublishTemplatedMessageTest.java | 4 +-
...tedMessageWithCustomEndpointFunctionalTest.java | 4 +-
...lishTemplatedMessageWithCustomEndpointTest.java | 4 +-
.../smn/PublishTextMessageFunctionalTest.java | 4 +-
.../huaweicloud/smn/PublishTextMessageTest.java | 6 +-
...extMessageWithCustomEndpointFunctionalTest.java | 4 +-
.../PublishTextMessageWithCustomEndpointTest.java | 6 +-
.../smn/constants/SmnPropertiesTest.java | 1 +
.../camel-ibm/camel-ibm-secrets-manager/pom.xml | 6 +
.../camel-ibm/camel-ibm-watson-discovery/pom.xml | 6 +
.../WatsonDiscoveryProducerQueryTest.java | 148 ++++
.../camel-ibm/camel-ibm-watson-language/pom.xml | 6 +
.../camel-ibm-watson-speech-to-text/pom.xml | 6 +
.../docs/ibm-watson-speech-to-text-component.adoc | 7 +
.../ibm/watson/stt/WatsonSpeechToTextProducer.java | 40 +-
.../stt/WatsonSpeechToTextAudioStreamTest.java | 313 ++++++++
.../camel-ibm-watson-text-to-speech/pom.xml | 6 +
.../component/ibm/watsonx/ai/ibm-watsonx-ai.json | 2 +-
.../src/main/docs/ibm-watsonx-ai-component.adoc | 13 +
.../ibm/watsonx/ai/WatsonxAiEndpoint.java | 21 +-
.../ai/handler/AbstractWatsonxAiHandler.java | 55 +-
.../ibm/watsonx/ai/WatsonxAiMessageBodyTest.java | 524 +++++++++++++
components/camel-ibm/pom.xml | 16 +
.../org/apache/camel/component/iggy/iggy.json | 15 +-
.../camel-iggy/src/main/docs/iggy-component.adoc | 24 +-
.../apache/camel/component/iggy/IggyConstants.java | 18 +
.../apache/camel/component/iggy/IggyEndpoint.java | 16 +-
.../camel/component/iggy/IggyFetchRecords.java | 3 +-
.../apache/camel/component/iggy/IggyProducer.java | 45 +-
.../camel/component/iggy/IggyConsumerIT.java | 2 +-
.../camel/component/iggy/IggyMessageBodyTest.java | 244 +++++++
.../apache/camel/component/iggy/IggyTestBase.java | 5 +-
.../apache/camel/component/jcr/JcrProducer.java | 2 +-
.../camel/component/jcr/JcrProducerTest.java | 24 +
.../org/apache/camel/component/jetty12/jetty.json | 2 +-
.../HttpChunkedNonStreamBodyAndFormStreamTest.java | 86 +++
.../component/jetty/HttpGzipNonStreamBodyTest.java | 66 ++
.../jetty/JettyMapHttpMessageBodyFalseTest.java | 52 ++
.../camel-jms/src/main/docs/jms-component.adoc | 8 +
.../org/apache/camel/component/jms/JmsBinding.java | 23 +-
.../camel/component/jms/JmsUnmappableBodyTest.java | 152 ++++
.../org/apache/camel/component/jooq/jooq.json | 4 +-
.../camel-jooq/src/main/docs/jooq-component.adoc | 3 +
.../camel/component/jooq/JooqConfiguration.java | 2 +-
.../apache/camel/component/jooq/JooqEndpoint.java | 9 +-
.../camel/component/jooq/JooqComponentTest.java | 12 +
.../component/jooq/JooqProducerEmptyBodyTest.java | 93 +++
.../org/apache/camel/component/jt400/jt400.json | 2 +-
.../camel-jt400/src/main/docs/jt400-component.adoc | 8 +-
.../camel/component/jt400/Jt400Endpoint.java | 23 +-
.../camel/component/jt400/Jt400PgmProducer.java | 31 +-
.../component/jt400/Jt400PgmProducerTest.java | 130 ++++
.../support/resume/KafkaResumeAdapter.java | 8 +-
.../support/resume/KafkaResumeAdapterTest.java | 61 +-
.../src/main/docs/language-component.adoc | 44 ++
.../camel/component/language/LanguageEndpoint.java | 5 +-
.../camel/component/language/LanguageProducer.java | 18 +-
.../observability/AsyncProcessorSpanTest.java | 89 +++
.../apache/camel/component/mina/MinaProducer.java | 10 +-
.../mina/MinaDisconnectOnTimeOutTest.java | 7 +-
.../mongodb/support/InMemoryStringResumeCache.java | 9 +-
.../src/main/docs/mybatis-component.adoc | 6 +
.../camel/component/mybatis/MyBatisProducer.java | 23 +-
.../mybatis/MyBatisInOutKeepsBodyTest.java | 127 ++++
.../mybatis/MyBatisInsertWithRollbackTest.java | 8 +-
.../component/mybatis/MyBatisNullBodyTest.java | 102 +++
.../org/apache/camel/component/mybatis/Account.xml | 15 +
.../src/main/docs/netty-http-component.adoc | 11 +
.../netty/http/HttpServerInitializerFactory.java | 9 +-
.../http/handlers/HttpServerChannelHandler.java | 31 +-
.../http/NettyHttpResponseCannotBeBuiltTest.java | 96 +++
...NettyHttpSSLServerHostnameVerificationTest.java | 132 ++++
.../camel-netty/src/main/docs/netty-component.adoc | 10 +
.../camel/component/netty/NettyConfiguration.java | 10 +
.../camel/component/netty/NettyPayloadHelper.java | 71 +-
.../netty/handlers/ClientChannelHandler.java | 9 +
.../netty/handlers/ServerChannelHandler.java | 44 +-
.../handlers/ServerResponseFutureListener.java | 9 +
.../netty/NettyDefaultCodecReplyTest.java | 91 +++
.../netty/NettyProducerSyncFalseReplyTest.java | 64 ++
.../netty/NettyReplyWriteFailureTest.java | 79 ++
...TransferExchangeAllowSerializedHeadersTest.java | 135 ++++
.../camel/component/netty/NettyUseByteBufTest.java | 86 +++
.../opentelemetry2/AsyncProcessorSpanTest.java | 119 +++
.../camel/component/optaplanner/optaplanner.json | 4 +-
.../src/main/docs/optaplanner-component.adoc | 12 +-
.../optaplanner/OptaPlannerComponent.java | 29 +
.../optaplanner/OptaPlannerConfiguration.java | 3 +-
.../component/optaplanner/OptaPlannerEndpoint.java | 75 +-
.../component/optaplanner/OptaPlannerProducer.java | 14 +-
.../OptaPlannerConfigFileSolverManagerTest.java | 79 ++
.../OptaPlannerConsumerCamelContextTest.java | 88 +++
.../optaplanner/OptaPlannerSyncConsumerTest.java | 63 ++
.../component/optaplanner/solverConfigQuick.xml | 38 +
.../pg/replication/slot/pg-replication-slot.json | 5 +-
.../main/docs/pg-replication-slot-component.adoc | 3 +
.../slot/PgReplicationSlotConstants.java} | 19 +-
.../slot/PgReplicationSlotConsumer.java | 2 +-
.../slot/PgReplicationSlotEndpoint.java | 6 +-
.../PgReplicationSlotConsumerReconnectTest.java | 21 +-
.../slot/PgReplicationSlotConsumerTest.java | 68 ++
.../src/main/docs/platform-http-vertx.adoc | 7 +
.../http/vertx/VertxPlatformHttpSupport.java | 15 +-
.../VertxPlatformHttpSingleValueResponseTest.java | 142 ++++
.../component/pubnub/PubNubConverterLoader.java | 60 ++
.../org/apache/camel/component/pubnub/pubnub.json | 2 +-
.../services/org/apache/camel/TypeConverterLoader | 2 +
.../src/main/docs/pubnub-component.adoc | 3 +
.../camel/component/pubnub/PubNubConverter.java | 45 ++
.../camel/component/pubnub/PubNubEndpoint.java | 3 +-
.../camel/component/pubnub/PubNubProducer.java | 10 +-
.../component/pubnub/PubNubConverterTest.java | 63 ++
.../component/pubnub/PubNubEmptyBodyTest.java | 92 +++
.../component/pubnub/PubNubSubscriberTest.java | 3 +
...PersistentStoreRestartAppChangeOptionsTest.java | 18 +-
...PersistentStoreRestartAppChangeOptionsTest1.xml | 2 +-
...PersistentStoreRestartAppChangeOptionsTest2.xml | 2 +-
.../component/robotframework/robotframework.json | 2 +-
.../src/main/docs/robotframework-component.adoc | 24 +-
.../robotframework/RobotFrameworkCamelUtils.java | 48 +-
.../robotframework/RobotFrameworkEndpoint.java | 2 +-
.../RobotFrameworkCamelUtilsTest.java | 46 ++
.../RobotFrameworkComponentTest.java | 24 +
.../robotframework/RobotFrameworkConsumerTest.java | 52 ++
.../set_variable_camel_no_body.robot | 27 +
components/camel-rocketmq/pom.xml | 4 +-
.../apache/camel/component/rocketmq/rocketmq.json | 44 +-
.../src/main/docs/rocketmq-component.adoc | 20 +-
.../component/rocketmq/RocketMQComponent.java | 8 +-
.../component/rocketmq/RocketMQConstants.java | 40 +-
.../camel/component/rocketmq/RocketMQEndpoint.java | 8 +-
.../camel/component/rocketmq/RocketMQProducer.java | 30 +-
.../rocketmq/RocketMQProducerSendFailureTest.java | 44 +-
.../camel-rss/src/main/docs/rss-component.adoc | 5 +
.../apache/camel/component/rss/RssEndpoint.java | 12 +-
.../component/rss/RssEntryCloneFailureTest.java | 136 ++++
.../camel/component/salesforce/salesforce.json | 6 +-
.../src/main/docs/salesforce-component.adoc | 2 +-
.../src/main/docs/salesforce-rest-api.adoc | 3 +
.../component/salesforce/SalesforceEndpoint.java | 9 +-
.../salesforce/SalesforceEndpointConfig.java | 5 +-
.../internal/processor/CompositeApiProcessor.java | 20 +-
.../CompositeSObjectCollectionsProcessor.java | 3 +
.../internal/processor/JsonRestProcessor.java | 13 +
.../internal/processor/RawProcessor.java | 4 +-
.../salesforce/ProducerRequestBodyTest.java | 205 ++++++
.../internal/processor/JsonRestProcessorTest.java | 49 ++
components/camel-sap-netweaver/pom.xml | 7 +
.../component/sap/netweaver/NetWeaverProducer.java | 17 +-
.../sap/netweaver/NetWeaverProducerTest.java | 118 +++
.../servicenow/AbstractServiceNowProcessor.java | 11 +-
.../component/servicenow/ServiceNowUnwrapTest.java | 117 +++
.../apache/camel/component/servlet/servlet.json | 2 +-
.../component/servlet/AttachmentHttpBinding.java | 11 +
.../component/servlet/MultipartUploadTest.java | 21 +
...rvletChunkedNonStreamBodyAndFormStreamTest.java | 110 +++
.../servlet/ServletGzipNonStreamBodyTest.java | 121 +++
.../ServletMapHttpMessageBodyFalseTest.java | 65 ++
.../org/apache/camel/component/sjms/sjms.json | 2 +-
.../camel-sjms/src/main/docs/sjms-component.adoc | 8 +-
.../apache/camel/component/sjms/SjmsEndpoint.java | 5 +-
.../sjms/consumer/EndpointMessageListener.java | 6 +
.../camel/component/sjms/jms/JmsBinding.java | 54 +-
.../consumer/InOutConsumerReplyFailureTest.java | 106 +++
.../sjms/producer/JmsMessageTypeTest.java | 37 +
.../sjms/producer/UnmappableBodyTest.java | 97 +++
.../org/apache/camel/component/sjms2/sjms2.json | 2 +-
.../camel-sjms2/src/main/docs/sjms2-component.adoc | 8 +-
.../camel/component/sjms2/Sjms2Endpoint.java | 5 +-
.../smooks/converter/SourceConverterLoader.java | 2 +-
.../src/main/docs/smooks-component.adoc | 4 +-
.../camel/component/smooks/SmooksProcessor.java | 69 +-
.../smooks/converter/SourceConverter.java | 23 +-
.../camel/component/smooks/routing/BeanRouter.java | 8 +-
.../component/smooks/SmooksReaderBodyTest.java | 204 ++++++
.../component/smooks/routing/BeanRouterTest.java | 47 ++
.../camel/component/spring/batch/spring-batch.json | 4 +-
.../src/main/docs/spring-batch-component.adoc | 8 +-
.../spring/batch/SpringBatchConstants.java | 3 +-
.../spring/batch/SpringBatchEndpoint.java | 2 +-
.../spring/batch/SpringBatchProducer.java | 15 +-
.../spring/batch/SpringBatchEndpointTest.java | 31 +
.../src/main/docs/spring-ws-component.adoc | 8 +
.../spring/ws/SpringWebserviceConsumer.java | 4 +-
.../spring/ws/SpringWebserviceHelper.java | 27 +
.../spring/ws/SpringWebserviceMessage.java | 24 +-
.../spring/ws/SpringWebserviceProducer.java | 3 +-
.../component/spring/ws/ConsumerReplyBodyTest.java | 137 ++++
.../spring/ws/ProducerLocalRouteTest.java | 45 ++
.../spring/ws/ConsumerReplyBodyTest-context.xml | 29 +
.../spring/ws/ProducerLocalRouteTest-context.xml | 13 +-
.../org/apache/camel/component/sql/sql.json | 4 +-
.../camel/component/sql/stored/sql-stored.json | 6 +-
.../camel-sql/src/main/docs/sql-component.adoc | 4 +
.../src/main/docs/sql-stored-component.adoc | 18 +
.../apache/camel/component/sql/SqlConstants.java | 5 +-
.../apache/camel/component/sql/SqlEndpoint.java | 4 +-
.../apache/camel/component/sql/SqlProducer.java | 20 +-
.../component/sql/stored/SqlStoredConstants.java | 6 +-
.../component/sql/stored/SqlStoredEndpoint.java | 8 +-
.../component/sql/stored/SqlStoredProducer.java | 21 +-
.../camel/component/sql/SqlProducerBatchTest.java | 198 +++++
.../component/sql/stored/ProducerBatchTest.java | 44 ++
.../org/apache/camel/component/stax/stax.json | 2 +-
.../camel-stax/src/main/docs/stax-component.adoc | 1 +
.../apache/camel/component/stax/StAXEndpoint.java | 8 +-
.../apache/camel/component/stax/StAXProcessor.java | 36 +-
.../camel/component/stax/StAXBodyTypesTest.java | 153 ++++
.../org/apache/camel/component/stripe/stripe.json | 4 +-
.../src/main/docs/stripe-component.adoc | 9 +-
.../camel/component/stripe/StripeConstants.java | 4 +-
.../camel/component/stripe/StripeEndpoint.java | 6 +-
.../camel/component/stripe/StripeProducer.java | 116 +--
.../stripe/StripeProducerRequestTest.java | 198 +++++
.../syslog/netty/Rfc5425FrameDecoder.java | 74 +-
.../syslog/netty/Rfc5425FrameDecoderTest.java | 130 ++++
.../camel/telemetrydev/AsyncProcessorSpanTest.java | 92 +++
.../TraceProcessorsInterceptStrategy.java | 55 +-
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../decorators/AbstractSpanDecorator.java | 21 +-
.../camel/telemetry/AsyncProcessorSpanTest.java | 284 ++++++++
.../telemetry/ProcessorSpanBeginFailureTest.java | 123 ++++
.../telemetry/ProcessorSpanEndFailureTest.java | 106 +++
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 ++-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../org/apache/camel/component/citrus/citrus.json | 2 +-
.../src/main/docs/citrus-component.adoc | 10 +
.../camel/component/citrus/CitrusEndpoint.java | 11 +-
.../citrus/CitrusValidationProcessor.java | 38 +-
.../citrus/CitrusValidateBodyTypesTest.java | 181 +++++
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../tracing/decorators/AbstractSpanDecorator.java | 21 +-
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 ++-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../directmessage/twitter-directmessage.json | 2 +-
.../twitter/timeline/twitter-timeline.json | 2 +-
.../main/docs/twitter-directmessage-component.adoc | 3 +-
.../directmessage/DirectMessageProducer.java | 4 +-
.../TwitterDirectMessageEndpoint.java | 2 +-
.../twitter/timeline/TwitterTimelineEndpoint.java | 2 +-
.../component/twitter/util/TwitterConverter.java | 3 +
.../twitter/DirectMessageProducerTest.java | 77 ++
.../component/twitter/TwitterConverterTest.java | 55 ++
.../twitter/TwitterTimelineEndpointTest.java | 41 ++
.../src/main/docs/undertow-component.adoc | 11 +
.../undertow/DefaultUndertowHttpBinding.java | 30 +-
.../camel/component/undertow/UndertowConsumer.java | 23 +-
.../camel/component/undertow/UndertowHelper.java | 45 ++
.../camel/component/undertow/UndertowProducer.java | 30 +-
.../undertow/UndertowBodyConversionTest.java | 218 ++++++
.../undertow/UndertowSwitchingStatus204Test.java | 6 +-
.../org/apache/camel/component/vertx/vertx.json | 8 +-
.../camel-vertx/src/main/docs/vertx-component.adoc | 19 +-
.../camel/component/vertx/VertxBodyHelper.java | 47 ++
.../camel/component/vertx/VertxConsumer.java | 12 +-
.../camel/component/vertx/VertxEndpoint.java | 24 +-
.../camel/component/vertx/VertxProducer.java | 34 +-
.../camel/component/vertx/VertxNullBodyTest.java | 140 ++++
.../vertx/VertxRequestReplyFailureTest.java | 18 +-
.../vertx/VertxRequestReplyStreamTest.java | 90 +++
.../whatsapp/WhatsAppWebhookProcessor.java | 44 +-
.../whatsapp/WhatsAppWebhookProcessorTest.java | 163 +++++
.../component/whatsapp/WhatsAppWebhookTest.java | 16 +
.../camel/component/wordpress/wordpress.json | 2 +-
.../src/main/docs/wordpress-component.adoc | 5 +
.../component/wordpress/WordpressEndpoint.java | 6 +-
.../producer/AbstractWordpressProducer.java | 37 +-
.../wordpress/producer/WordpressPostProducer.java | 8 +-
.../wordpress/producer/WordpressUserProducer.java | 10 +-
.../wordpress/WordpressPostOperationTest.java | 63 ++
.../wordpress/WordpressUserOperationTest.java | 46 ++
.../test/WordpressServerHttpRequestHandler.java | 20 +
.../camel/component/zendesk/ZendeskComponent.java | 4 +
.../zendesk/AbstractZendeskTestSupport.java | 8 +-
.../component/zendesk/ZendeskApiNameTest.java | 101 +++
.../org/apache/camel/resume/cache/ResumeCache.java | 11 +-
.../engine/DefaultAsyncProcessorAwaitManager.java | 35 +-
.../org/apache/camel/impl/engine/DefaultRoute.java | 5 +-
.../camel/impl/engine/DefaultShutdownStrategy.java | 85 ++-
.../engine/DefaultSupervisingRouteController.java | 29 +-
.../modules/languages/pages/tokenize-language.adoc | 5 +
core/camel-core-processor/pom.xml | 7 +
.../apache/camel/processor/AbstractThrottler.java | 20 +
.../processor/ConcurrentRequestsThrottler.java | 7 +-
.../apache/camel/processor/MulticastProcessor.java | 16 +-
.../java/org/apache/camel/processor/Splitter.java | 26 +-
.../camel/processor/TotalRequestsThrottler.java | 12 +-
.../errorhandler/RedeliveryErrorHandler.java | 98 ++-
.../processor/resume/TransientResumeStrategy.java | 13 +-
.../resume/TransientResumeStrategyCacheTest.java | 104 +++
.../language/TokenizerExpressionReifier.java | 20 +-
.../converter/stream/StreamCacheConverterTest.java | 27 +-
...faultAsyncProcessorAwaitManagerProcessTest.java | 128 ++++
...aultShutdownStrategyConcurrentShutdownTest.java | 420 +++++++++++
...singRouteControllerRemoveRouteDeadlockTest.java | 347 +++++++++
.../ConstantLanguageBinaryResourceTest.java | 40 +
.../org/apache/camel/language/TokenizerTest.java | 8 +-
.../tokenizer/TokenizeLiteralTokenTest.java | 139 ++++
.../SplitterNestedFailureTrackerLeakTest.java | 73 ++
.../processor/SplitterTestResumeStrategy.java | 9 +-
.../camel/processor/SplitterWatermarkTest.java | 19 +
.../processor/ToVariableReceiveHeadersTest.java | 56 +-
.../SimpleTaskProcessorThrowsPooledTest.java | 38 +
.../SimpleTaskProcessorThrowsTest.java | 341 +++++++++
.../SimpleTaskProcessorThrowsTestSupport.java | 199 +++++
.../ConcurrentRequestsThrottlerCleanTest.java | 23 +-
.../throttle/requests/ThrottlingGroupingTest.java | 15 +-
.../requests/TotalRequestsThrottlerCleanTest.java | 38 +-
.../camel/management/mbean/StatisticCounter.java | 5 +-
.../mbean/ManagedPerformanceCounterTest.java | 25 +
.../org/apache/camel/support/ExchangeHelper.java | 27 +-
.../apache/camel/support/GroupTokenIterator.java | 14 +-
.../camel/support/builder/ExpressionBuilder.java | 9 +-
.../builder/TokenPairExpressionIterator.java | 22 +-
.../apache/camel/util/ImportantHeaderUtils.java | 2 +-
.../main/java/org/apache/camel/util/StopWatch.java | 4 +-
.../java/org/apache/camel/util/StopWatchTest.java | 36 +
.../apache/camel/converter/jaxp/XmlConverter.java | 16 +-
.../camel/util/xml/StreamSourceConverter.java | 14 +-
design/chaos.adoc | 53 +-
.../modules/ROOT/attachments/security-model.yaml | 3 +
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 32 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_21.adoc | 2 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 30 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 811 +++++++++++++++++++++
.../modules/ROOT/pages/camel-jbang-managing.adoc | 17 +
.../modules/ROOT/pages/camel-jbang-mcp.adoc | 7 +-
.../modules/ROOT/pages/camel-jbang-running.adoc | 7 +
.../modules/ROOT/pages/camel-jbang-test.adoc | 18 +-
.../jbang-commands/camel-jbang-cmd-chaos-add.adoc | 27 +
.../camel-jbang-cmd-chaos-change.adoc | 28 +
.../camel-jbang-cmd-chaos-clear.adoc | 26 +
.../camel-jbang-cmd-chaos-remove.adoc | 27 +
.../ROOT/pages/jbang-commands/camel-jbang-cmd.adoc | 4 +
.../pages/jbang-commands/camel-jbang-debug.adoc | 1 +
.../ROOT/pages/jbang-commands/camel-jbang-dev.adoc | 1 +
.../jbang-commands/camel-jbang-get-chaos.adoc | 30 +
.../ROOT/pages/jbang-commands/camel-jbang-get.adoc | 1 +
.../ROOT/pages/jbang-commands/camel-jbang-run.adoc | 1 +
.../modules/ROOT/pages/security-model.adoc | 11 +-
docs/user-manual/modules/ROOT/pages/variables.adoc | 13 +
dsl/camel-cli-connector/pom.xml | 6 +
.../apache/camel/cli/connector/ChaosAction.java | 140 ++++
.../camel/cli/connector/LocalCliConnector.java | 10 +
.../LocalCliConnectorChaosActionTest.java | 344 +++++++++
...BedrockAgentRuntimeComponentBuilderFactory.java | 6 +-
.../dsl/AwsBedrockComponentBuilderFactory.java | 6 +-
.../dsl/AzureFunctionsComponentBuilderFactory.java | 21 +
.../dsl/RocketmqComponentBuilderFactory.java | 8 +-
.../dsl/SalesforceComponentBuilderFactory.java | 6 +-
.../builder/endpoint/EndpointHeaderBuilders.java | 53 ++
.../builder/endpoint/StaticEndpointBuilders.java | 40 +-
.../AtmosphereWebsocketEndpointBuilderFactory.java | 44 +-
.../BedrockAgentRuntimeEndpointBuilderFactory.java | 11 +-
.../dsl/BedrockEndpointBuilderFactory.java | 23 +-
.../endpoint/dsl/BonitaEndpointBuilderFactory.java | 36 +
.../dsl/ClickHouseEndpointBuilderFactory.java | 4 +-
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 15 +
.../endpoint/dsl/DuckDbEndpointBuilderFactory.java | 7 +-
.../endpoint/dsl/FlinkEndpointBuilderFactory.java | 8 +-
.../dsl/FunctionsEndpointBuilderFactory.java | 36 +
...gleCloudTextToSpeechEndpointBuilderFactory.java | 4 +-
.../dsl/GoogleDriveEndpointBuilderFactory.java | 51 +-
.../dsl/GoogleMailEndpointBuilderFactory.java | 12 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 10 +-
.../dsl/GoogleVertexAIEndpointBuilderFactory.java | 27 +-
.../endpoint/dsl/IggyEndpointBuilderFactory.java | 134 ++++
.../dsl/JettyHttp12EndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/MNSEndpointBuilderFactory.java | 9 +-
.../endpoint/dsl/OSSEndpointBuilderFactory.java | 40 +
.../dsl/OptaPlannerEndpointBuilderFactory.java | 9 +-
.../PgReplicationSlotEndpointBuilderFactory.java | 39 +
.../dsl/RocketMQEndpointBuilderFactory.java | 136 ++--
.../dsl/SalesforceEndpointBuilderFactory.java | 36 +-
.../dsl/ServletEndpointBuilderFactory.java | 14 +-
.../dsl/SpringBatchEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java | 5 +-
.../dsl/SqlStoredEndpointBuilderFactory.java | 5 +-
.../endpoint/dsl/StripeEndpointBuilderFactory.java | 3 +-
.../dsl/TwitterTimelineEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/VertxEndpointBuilderFactory.java | 24 +-
dsl/camel-jbang/camel-jbang-core/pom.xml | 5 +-
.../META-INF/camel-jbang-commands-metadata.json | 10 +-
.../dsl/jbang/core/commands/CamelJBangMain.java | 5 +
.../camel/dsl/jbang/core/commands/Debug.java | 1 +
.../apache/camel/dsl/jbang/core/commands/Run.java | 111 ++-
.../core/commands/action/CamelChaosAction.java | 118 +++
.../core/commands/action/CamelChaosAddAction.java | 60 ++
.../commands/action/CamelChaosChangeAction.java | 62 ++
.../commands/action/CamelChaosClearAction.java | 50 ++
.../commands/action/CamelChaosRemoveAction.java | 55 ++
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 85 ++-
.../dsl/jbang/core/commands/ai/CatalogSamples.java | 5 +-
.../core/commands/ai/HeaderPropertyMixups.java | 116 +++
.../core/commands/ai/IntegrationLauncher.java | 62 +-
.../dsl/jbang/core/commands/ai/OpenApiVerbs.java | 38 +
.../dsl/jbang/core/commands/ai/SimpleChecks.java | 162 +++-
.../jbang/core/commands/ai/SourceValidator.java | 59 +-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 29 +-
.../dsl/jbang/core/commands/ai/ValidatorFacts.java | 175 ++++-
.../dsl/jbang/core/commands/ai/WriteNotes.java | 401 ++++++++++
.../dsl/jbang/core/commands/process/ListChaos.java | 303 ++++++++
.../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 | 40 +
.../dsl/jbang/core/commands/RunDirectoryTest.java | 27 +
.../jbang/core/commands/RunExportGoldenTest.java | 8 +-
.../camel/dsl/jbang/core/commands/RunTest.java | 39 +
.../core/commands/action/CamelChaosActionTest.java | 241 ++++++
.../core/commands/ai/AuthoringToolsCitrusTest.java | 221 ++++++
.../core/commands/ai/AuthoringToolsEditTest.java | 79 ++
.../jbang/core/commands/ai/CatalogSamplesTest.java | 21 +
.../core/commands/ai/ExampleToolsRegistryTest.java | 54 +-
.../core/commands/ai/HeaderPropertyMixupsTest.java | 61 ++
.../core/commands/ai/IntegrationLauncherTest.java | 70 ++
.../commands/ai/SourceValidatorSimpleTest.java | 75 ++
.../jbang/core/commands/ai/ToolConfirmsTest.java | 17 +
.../jbang/core/commands/ai/ValidatorFactsTest.java | 105 +++
.../dsl/jbang/core/commands/ai/WriteNotesTest.java | 207 ++++++
.../jbang/core/commands/process/ListChaosTest.java | 264 +++++++
.../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 | 191 ++++-
.../test/resources/golden/expected/chaos.run.txt | 49 ++
.../golden/expected/maven-main-chaos.maven.txt | 56 ++
.../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 +
.../camel/dsl/jbang/run/CamelMainRunner.java | 3 +
.../camel/dsl/jbang/run/MavenRunSupport.java | 4 +
.../org/apache/camel/dsl/jbang/run/RunFiles.java | 114 ++-
.../apache/camel/dsl/jbang/run/RunPipeline.java | 13 +-
.../org/apache/camel/dsl/jbang/run/RunRequest.java | 5 +
.../camel/dsl/jbang/run/common/ExportHelper.java | 3 +-
.../camel/dsl/jbang/run/ProjectRunnerTest.java | 32 +-
.../apache/camel/dsl/jbang/run/RunFilesTest.java | 122 ++++
dsl/camel-jbang/camel-launcher/pom.xml | 23 +
.../camel/dsl/yaml/validator/JsonPathText.java | 147 ++++
.../camel/dsl/yaml/validator/ProjectFacts.java | 16 +-
.../camel/dsl/yaml/validator/RouteGraph.java | 81 ++
.../camel/dsl/yaml/validator/SchemaHints.java | 91 +++
.../camel/dsl/yaml/validator/TextBodyFlow.java | 351 ++++++++-
.../camel/dsl/yaml/validator/YamlValidator.java | 256 ++++++-
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 179 ++++-
.../validator/YamlValidatorPropertyHintTest.java | 365 ++++++++++
parent/pom.xml | 60 +-
.../src/generated/resources/META-INF/metadata.json | 52 +-
.../test/infra/aws2/services/container.properties | 2 +-
.../infra/clickhouse/services/container.properties | 2 +-
.../infra/docling/services/container.properties | 2 +-
.../test/infra/kafka/services/container.properties | 4 +-
.../infra/milvus/services/container.properties | 2 +-
.../infra/ollama/services/container.properties | 2 +-
.../test/infra/opa/services/container.properties | 2 +-
.../infra/openfga/services/container.properties | 2 +-
.../infra/pulsar/services/container.properties | 2 +-
.../test/infra/redis/services/container.properties | 2 +-
.../rocketmq/services/RocketMQBrokerContainer.java | 72 +-
976 files changed, 40450 insertions(+), 3140 deletions(-)
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/dev-consoles/chaos.json
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/runtime/stream/Ai21StreamParser.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/stream/NovaStreamParser.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/test/java/org/apache/camel/component/aws2/bedrock/agentruntime/BedrockAgentRuntimeProducerOperationTest.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/test/java/org/apache/camel/component/aws2/bedrock/runtime/BedrockProducerRequestTest.java
create mode 100644
components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerResultHeadersTest.java
create mode 100644
components/camel-azure/camel-azure-eventgrid/src/test/java/org/apache/camel/component/azure/eventgrid/EventGridProducerTest.java
create mode 100644
components/camel-azure/camel-azure-functions/src/test/java/org/apache/camel/component/azure/functions/FunctionsProducerInvokeTest.java
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-bonita/src/main/java/org/apache/camel/component/bonita/BonitaConstants.java}
(69%)
create mode 100644
components/camel-bonita/src/test/java/org/apache/camel/component/bonita/BonitaStartProducerTest.java
create mode 100644
components/camel-camunda/src/test/java/org/apache/camel/component/camunda/CamundaProducerTest.java
create mode 100644
components/camel-chaos/src/generated/resources/META-INF/org/apache/camel/dev-console/chaos.json
create mode 100644
components/camel-chaos/src/generated/resources/META-INF/services/org/apache/camel/dev-console/chaos
create mode 100644
components/camel-chaos/src/generated/resources/META-INF/services/org/apache/camel/dev-consoles.properties
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosDevConsole.java
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosLifecycle.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosDevConsoleTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosLifecycleStartupTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosLifecycleTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosNettyHttpFaultTest.java
create mode 100644
components/camel-clickup/src/main/java/org/apache/camel/component/clickup/model/GenericEvent.java
create mode 100644
components/camel-clickup/src/test/resources/messages/events/task-created.json
create mode 100644
components/camel-cxf/camel-cxf-rest/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumerUnchangedBodyTest.java
copy
components/{camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/BedrockOperations.java
=>
camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/BodyTypeService.java}
(71%)
create mode 100644
components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfBodyTypesTest.java
copy
test-infra/camel-test-infra-pulsar/src/main/resources/org/apache/camel/test/infra/pulsar/services/container.properties
=>
components/camel-cxf/camel-cxf-soap/src/test/resources/junit-platform.properties
(86%)
create mode 100644
components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/mongodb/DebeziumMongodbEndpointTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorVmSharedQueueReferenceTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/vm/DisruptorVmComponentStartCounterTest.java
create mode 100644
components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/routing/DynamicRouterRemoveRouteTest.java
create mode 100644
components/camel-ehcache/src/test/java/org/apache/camel/component/ehcache/EhcacheDefaultsTest.java
create mode 100644
components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetRow.java
create mode 100644
components/camel-flatpack/src/test/java/org/apache/camel/component/flatpack/FlatpackSplitRowsTest.java
create mode 100644
components/camel-flink/src/test/java/org/apache/camel/component/flink/DataStreamComponentOptionsAndCollectTest.java
create mode 100644
components/camel-flowable/src/test/java/org/apache/camel/component/flowable/FlowableProducerChannelNotDeployedTest.java
create mode 100644
components/camel-flowable/src/test/resources/channel/userRouteChannel.channel
create mode 100644
components/camel-fop/src/test/java/org/apache/camel/component/fop/FopBodyTest.java
create mode 100644
components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/unit/GoogleBigQueryComponentConnectionFactoryTest.java
create mode 100644
components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/unit/sql/GoogleBigQuerySQLProducerStatementTest.java
create mode 100644
components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveRequestHelper.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveMediaContentTest.java
create mode 100644
components/camel-google/camel-google-functions/src/test/java/org/apache/camel/component/google/functions/unit/GoogleCloudFunctionsCallFunctionTest.java
create mode 100644
components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/GoogleMailApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-secret-manager/src/test/java/org/apache/camel/component/google/secret/manager/unit/GoogleSecretManagerCreateSecretTest.java
create mode 100644
components/camel-google/camel-google-sheets/src/test/java/org/apache/camel/component/google/sheets/GoogleSheetsApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-text-to-speech/src/test/java/org/apache/camel/component/google/texttospeech/unit/GoogleCloudTextToSpeechProducerTest.java
create mode 100644
components/camel-google/camel-google-vertexai/src/test/java/org/apache/camel/component/google/vertexai/GoogleVertexAIProducerBodyTest.java
create mode 100644
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQProducerBodyTest.java
create mode 100644
components/camel-http-common/src/test/java/org/apache/camel/http/common/DefaultHttpBindingGzipTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-dms/src/test/java/org/apache/camel/component/huaweicloud/dms/InstanceRequestBodyTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-functiongraph/src/test/java/org/apache/camel/InvokeFunctionBodyTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-iam/src/test/java/org/apache/camel/component/huaweicloud/iam/IAMProducerJsonTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/PutObjectMandatoryNamesTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishMessageBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-watson-discovery/src/test/java/org/apache/camel/component/ibm/watson/discovery/WatsonDiscoveryProducerQueryTest.java
create mode 100644
components/camel-ibm/camel-ibm-watson-speech-to-text/src/test/java/org/apache/camel/component/ibm/watson/stt/WatsonSpeechToTextAudioStreamTest.java
create mode 100644
components/camel-ibm/camel-ibm-watsonx-ai/src/test/java/org/apache/camel/component/ibm/watsonx/ai/WatsonxAiMessageBodyTest.java
create mode 100644
components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyMessageBodyTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpChunkedNonStreamBodyAndFormStreamTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpGzipNonStreamBodyTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyMapHttpMessageBodyFalseTest.java
create mode 100644
components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsUnmappableBodyTest.java
create mode 100644
components/camel-jooq/src/test/java/org/apache/camel/component/jooq/JooqProducerEmptyBodyTest.java
create mode 100644
components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmProducerTest.java
create mode 100644
components/camel-micrometer-observability/src/test/java/org/apache/camel/micrometer/observability/AsyncProcessorSpanTest.java
create mode 100644
components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisInOutKeepsBodyTest.java
create mode 100644
components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisNullBodyTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpResponseCannotBeBuiltTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpSSLServerHostnameVerificationTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyDefaultCodecReplyTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyProducerSyncFalseReplyTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyReplyWriteFailureTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTransferExchangeAllowSerializedHeadersTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseByteBufTest.java
create mode 100644
components/camel-opentelemetry2/src/test/java/org/apache/camel/opentelemetry2/AsyncProcessorSpanTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerConfigFileSolverManagerTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerConsumerCamelContextTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerSyncConsumerTest.java
create mode 100644
components/camel-optaplanner/src/test/resources/org/apache/camel/component/optaplanner/solverConfigQuick.xml
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConstants.java}
(57%)
create mode 100644
components/camel-pg-replication-slot/src/test/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumerTest.java
create mode 100644
components/camel-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpSingleValueResponseTest.java
create mode 100644
components/camel-pubnub/src/generated/java/org/apache/camel/component/pubnub/PubNubConverterLoader.java
create mode 100644
components/camel-pubnub/src/generated/resources/META-INF/services/org/apache/camel/TypeConverterLoader
create mode 100644
components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubConverter.java
create mode 100644
components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubConverterTest.java
create mode 100644
components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubEmptyBodyTest.java
create mode 100644
components/camel-robotframework/src/test/java/org/apache/camel/component/robotframework/RobotFrameworkConsumerTest.java
create mode 100644
components/camel-robotframework/src/test/resources/org/apache/camel/component/robotframework/set_variable_camel_no_body.robot
create mode 100644
components/camel-rss/src/test/java/org/apache/camel/component/rss/RssEntryCloneFailureTest.java
create mode 100644
components/camel-salesforce/camel-salesforce-component/src/test/java/org/apache/camel/component/salesforce/ProducerRequestBodyTest.java
create mode 100644
components/camel-sap-netweaver/src/test/java/org/apache/camel/component/sap/netweaver/NetWeaverProducerTest.java
create mode 100644
components/camel-servicenow/camel-servicenow-component/src/test/java/org/apache/camel/component/servicenow/ServiceNowUnwrapTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletChunkedNonStreamBodyAndFormStreamTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletGzipNonStreamBodyTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletMapHttpMessageBodyFalseTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerReplyFailureTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/UnmappableBodyTest.java
create mode 100644
components/camel-smooks/src/test/java/org/apache/camel/component/smooks/SmooksReaderBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ws/src/test/java/org/apache/camel/component/spring/ws/ConsumerReplyBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ws/src/test/resources/org/apache/camel/component/spring/ws/ConsumerReplyBodyTest-context.xml
create mode 100644
components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerBatchTest.java
create mode 100644
components/camel-stax/src/test/java/org/apache/camel/component/stax/StAXBodyTypesTest.java
create mode 100644
components/camel-stripe/src/test/java/org/apache/camel/component/stripe/StripeProducerRequestTest.java
create mode 100644
components/camel-syslog/src/test/java/org/apache/camel/component/syslog/netty/Rfc5425FrameDecoderTest.java
create mode 100644
components/camel-telemetry-dev/src/test/java/org/apache/camel/telemetrydev/AsyncProcessorSpanTest.java
create mode 100644
components/camel-telemetry/src/test/java/org/apache/camel/telemetry/AsyncProcessorSpanTest.java
create mode 100644
components/camel-telemetry/src/test/java/org/apache/camel/telemetry/ProcessorSpanBeginFailureTest.java
create mode 100644
components/camel-telemetry/src/test/java/org/apache/camel/telemetry/ProcessorSpanEndFailureTest.java
create mode 100644
components/camel-test/camel-test-citrus/src/test/java/org/apache/camel/component/citrus/CitrusValidateBodyTypesTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageProducerTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/TwitterConverterTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/TwitterTimelineEndpointTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/UndertowBodyConversionTest.java
create mode 100644
components/camel-vertx/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxBodyHelper.java
create mode 100644
components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxNullBodyTest.java
create mode 100644
components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyStreamTest.java
create mode 100644
components/camel-whatsapp/src/test/java/org/apache/camel/component/whatsapp/WhatsAppWebhookProcessorTest.java
create mode 100644
components/camel-zendesk/src/test/java/org/apache/camel/component/zendesk/ZendeskApiNameTest.java
create mode 100644
core/camel-core-processor/src/test/java/org/apache/camel/processor/resume/TransientResumeStrategyCacheTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/DefaultAsyncProcessorAwaitManagerProcessTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultShutdownStrategyConcurrentShutdownTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultSupervisingRouteControllerRemoveRouteDeadlockTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/language/tokenizer/TokenizeLiteralTokenTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/SimpleTaskProcessorThrowsPooledTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/SimpleTaskProcessorThrowsTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/errorhandler/SimpleTaskProcessorThrowsTestSupport.java
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-add.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-change.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-clear.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-remove.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-get-chaos.adoc
create mode 100644
dsl/camel-cli-connector/src/main/java/org/apache/camel/cli/connector/ChaosAction.java
create mode 100644
dsl/camel-cli-connector/src/test/java/org/apache/camel/cli/connector/LocalCliConnectorChaosActionTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosAddAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosChangeAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosClearAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosRemoveAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ai/WriteNotes.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/process/ListChaos.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/action/CamelChaosActionTest.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/java/org/apache/camel/dsl/jbang/core/commands/ai/WriteNotesTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/commands/process/ListChaosTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/golden/citrus/test/orders.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/golden/expected/chaos.run.txt
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/golden/expected/maven-main-chaos.maven.txt
create mode 100644
dsl/camel-jbang/camel-jbang-run/src/test/java/org/apache/camel/dsl/jbang/run/RunFilesTest.java
create mode 100644
dsl/camel-yaml-dsl/camel-yaml-dsl-validator/src/main/java/org/apache/camel/dsl/yaml/validator/JsonPathText.java
