This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-25334-payload-mode-design
in repository https://gitbox.apache.org/repos/asf/camel.git
from 1e244a99cecd Merge branch 'main' into CAMEL-25334-payload-mode-design
add cd70aab26f3b chore(deps): Bump com.stripe:stripe-java from 34.0.0 to
34.1.0
add cba52a2da111 chore(deps): Bump com.couchbase.client:java-client from
3.12.3 to 3.13.0
add 1164a1797764 CAMEL-26600: Fix flaky CxfProducerOperationTest by
configuring short timeout on wrong endpoint
add f321752362b7 CAMEL-26547: camel-pqc - a stateful signature key is
claimed for one process (#29098)
add e413bf8987c8 CAMEL-26549: camel-ftp, camel-mina-sftp - the SFTP and
SCP clients can negotiate the post-quantum key exchange (#29094)
add 39f53df14149 CAMEL-26256: camel-cyberark-vault - retry a rejected
token once and only when a new one can be obtained, and check the credentials
at endpoint start (#29209)
add 2931a16505eb CAMEL-26279: camel-cyberark-vault - apply verifySsl and
certificatePath to the client, URL-encode the secret version, and set the
secret only as the body on getSecret (#29210)
add a14ae8b421b3 CAMEL-26274: camel-docker - honour the connection and
credential headers only with allowConnectionAndCredentialsFromHeaders=true
(#29211)
add d8e538bc9fd1 CAMEL-26275: camel-keycloak - take the operation from the
CamelKeycloakOperation header only when allowOperationHeader is set (#29212)
add 664692c4f6ed CAMEL-26300: camel-pinecone - pinecone:embeddings stores
the text pinecone:rag reads, and names a missing embedding header (#29213)
add 2fa665b8a08b CAMEL-26300: camel-milvus, camel-neo4j, camel-qdrant,
camel-weaviate - the embeddings transformers name a missing embedding header,
and neo4j:rag converts a text that is not a String (#29214)
add 8d987d91e21f CAMEL-26300: camel-jackson and camel-jackson3 -
application-json writes a Map, a List, text, bytes and a stream, avro-x-struct
reads Json text, the Java object transformers fail clearly on a null body and
read a JsonNode with Jackson 2 too, and the Jackson 3 Avro and Protobuf
transformers wrap their errors (#29215)
add 46b3a1949ab5 CAMEL-26300: camel-aws2-sqs, camel-aws2-ddb - the SQS
CloudEvent source names the queue, and the DynamoDB x-struct transformer reads
stream and file bodies as text (#29216)
add fe8f4ef8bd63 CAMEL-26300: camel-google-calendar - the CloudEvent
transformer fails with a clear message on a body that is not an Event (#29217)
add e9e2f85c5803 CAMEL-26488: camel-mina - sync the producer timeout
upgrade note to the 4.22 and 4.18 guides on main (#29218)
add 92b23246dbbf CAMEL-26542: camel-elasticsearch - do not reuse a built
SearchRequest.Builder in the converter (#29224)
add bfc5f60d1a5e CAMEL-26575: camel-core - Multicast, Split and
RecipientList: an AggregationStrategy whose onCompletion throws fails the
exchange instead of hanging it (#29200)
add 62cf348fd7ec CAMEL-26576: camel-core - shareUnitOfWork: a part sent to
seda hands over only its own on completions (#29203)
add 49a0b3fed1af CAMEL-26611: camel-micrometer,
camel-opentelemetry-metrics - use tags and attributes from headers as given
(#29223)
add 05be4fd05831 CAMEL-26612: camel-jbang - camel eval --isolated and
camel transform message do not load the plugins (#29222)
add 8fc0dc2f36bb CAMEL-26577: camel-support -
RebalancingCamelClusterService: release the views a rebalancing pass looks at
(#29202)
add 4c8538b63242 CAMEL-26494: camel-jbang - camel run --dev with a source
directory does not reload the routes when a file in the test folder changes
(#28874)
add 0a5082e633a4 CAMEL-26615: camel-azure-storage-datalake - run the
integration tests on Floci AZ (#29229)
add 64c7d519de70 CAMEL-25675: camel-hashicorp-vault - log in with AppRole,
Kubernetes or JWT, and renew the token (#29235)
add 942ec097ce18 CAMEL-26494: camel-jbang - update the RunExportGoldenTest
golden file for the reload pattern that skips the test folder
add a80092bc631f CAMEL-25824: camel-pqc - the hybrid KEM operations stamp
the JCE algorithm name on the secret key (#29220)
add cdf2960a6bb7 CAMEL-26606: camel-platform-http-vertx - fail the start
when the HTTP server cannot bind its port (#29221)
add d4b286bdd929 CAMEL-26552: camel-kubernetes - custom resources
producer: header namespace takes precedence over the endpoint option (#29242)
add 9278a119357c CAMEL-26637: camel-azure-cosmosdb - createContainer does
not normalize the partition key path (#29243)
add e439e62a13eb CAMEL-26585: Document SNS array fix in LTS upgrade guides
(#29233)
add b40c2e3c5b33 CAMEL-26617: camel-azure-key-vault - run the integration
tests on Floci AZ (#29237)
add c3722335c18e CAMEL-26632: camel-jbang - AI tools and messages:
resource: in a ternary, a header copied to itself, a condition under
otherwise:, variableReceive under parameters:, a Groovy class without its
import, and text after a Simple function (#29230)
add 553e7887a411 CAMEL-26638: camel-hazelcast - fix flaky
HazelcastReliableTopicConsumerLossTest.listenerCancelledByHazelcastIsReported
(#29248)
add 54b541b382c1 CAMEL-26611: camel-micrometer,
camel-opentelemetry-metrics - upgrade guide notes for 4.22.3 and 4.18.6 (#29262)
add 7978db3d42dd CAMEL-26635: camel-file, camel-sftp, camel-mina-sftp,
camel-smb - stop listing the directory once maxMessagesPerPoll files are
accepted (#29246)
add 39039a5ce040 CAMEL-26281: camel-whatsapp - verify the
X-Hub-Signature-256 signature of webhook events by default (#29260)
add 1eb880fa6d6d CAMEL-26627: camel-debezium - Upgrade to Debezium
3.7.0.Final (#29225)
add e642b53badb2 CAMEL-26636: camel-jbang - TUI: the AI panel no longer
cuts the longest catalog answers (#29231)
add 8e285fd0fa9f CAMEL-26644: Normalize file component path separators for
getFile/directory consistency (#29250)
add a910bc51d95b CAMEL-26645: camel-core - Supervising route controller:
route consumers get the application class loader as TCCL (#29263)
add 9972ed33b1f4 CAMEL-26654: camel-azure-storage-datalake - getFile
writes only into an OutputStream body (#29268)
add 136340e24577 CAMEL-26649: camel-aws2-sqs - the consumer receives up to
10 messages per poll by default (#29271)
add 137c0ef57dc3 CAMEL-26606: camel-platform-http-vertx - upgrade guide
note for 4.22.3 (#29264)
add 6d21c2113b6d CAMEL-26581: Document Calendar paging fix in LTS upgrade
guides (#29244)
add 3f0ea5674020 CAMEL-26584: Document Bedrock pagination fix in 4.22
upgrade guide (#29234)
add 2d97a2141484 CAMEL-26281: Sync the camel-whatsapp webhook upgrade
guide notes for 4.22.3 and 4.18.6 to main (#29280)
add d224bceef2db CAMEL-26663: camel-hazelcast -
HazelcastAggregationRepository optimistic remove() no longer loses a completed
group (#29278)
add 24af73b6b568 CAMEL-25962: camel-kamelet - stop waiting for ever for a
busy thread pool before removing a Kamelet's route (#29292)
add 5d8aa35dcd24 CAMEL-25980: camel-aws-secrets-manager - the CloudTrail
refresh task reads the updates that CloudTrail makes visible late (#29291)
add 7836b5102c1f CAMEL-25960: camel-file - keep the done file of a poll
for its last file that completes asynchronously (#29290)
add b2e39a7c0951 CAMEL-26066: camel-jsch - the scp producer refuses a file
name with a line feed or a NUL character (#29285)
add bcf16b93c9bc CAMEL-26662, CAMEL-26661: camel-aws2-s3 - get each object
just before routing it, and use HeadObject for ignoreBody (#29274)
add 14d840974f9c CAMEL-26650: camel-aws2-kinesis - the consumer fetches up
to 1000 records per shard in each poll by default (#29272)
add 3651230156ec CAMEL-26651, CAMEL-26652: camel-git - consumer honours
scheduler options and redelivers failed items (#29270)
add 6827b9194109 CAMEL-26660: camel-aws2-kinesis - batch producer sends
the failed records again and splits requests at 10 MiB (#29269)
add a7770bd1d891 CAMEL-26551: camel-dapr - the secret operation takes the
secret store, key and metadata from the endpoint unless
allowSecretStoreAndKeyFromHeaders=true (#29283)
add 3a3479946b78 CAMEL-26042: camel-aws2-sts - do not copy the temporary
secret key and session token into message headers (#29281)
add 74380be01ab1 CAMEL-26543: camel-huggingface - chat turns of one memory
ID run one at a time (#29279)
add eee42db1f2b5 CAMEL-26550: camel-grpc - routeControlledStreamObserver
lets the route reply to streaming requests with the PROPAGATION strategy
(#29277)
add e8a5c53c89d3 CAMEL-26601: camel-core - Recipient list in a doTry: a
producer that throws fails the exchange instead of hanging (#29295)
add 33accc67f274 CAMEL-25731: camel-mongodb - log the stack trace only for
the first of consecutive cursor failures (#29294)
add 393c2d6a2953 CAMEL-25733: camel-mail - remove the idempotent key of
the mail whose processExchange throws, not only of the rest of the batch
(#29289)
add 17bf5c4d9fde CAMEL-26598: camel-kafka - breakOnFirstError replays the
failed record also when the consumer is paused (#29287)
add 28e8688b015a chore(deps): Bump the elasticsearch group with 3 updates
add 3c5b6dd85c9f CAMEL-26674: camel-chaos - reject rules that cannot work
(#29303)
add f8c76e97f9fe CAMEL-26067: camel-jdbc - plain ? placeholders take their
values only from the CamelJdbcParameters header (#29282)
add 827bcd581d40 CAMEL-26359: camel-mcp-server - check the Origin header
on /mcp (Camel Main engine) (#29284)
add 0fc8fcaa8b1c CAMEL-26628: camel-undertow - Fix flaky
UndertowHttpsSpringTest (Address already in use)
add 56237588cb0b CAMEL-26492: check multi-arch manifest before proposing
container upgrades (#29149)
add 1b84527b4940 CAMEL-26629: Try to stabilize
JettyHttpEndpointDisconnectTest (#29227)
add 6705f9c9985d CAMEL-25961: camel-xmpp - producers log in and the group
chat producer enters its room again after a lost connection (#29293)
add ca9ca659f8f4 CAMEL-26519: camel-catalog - DocExamplesXmlSchemaTest no
longer depends on the locale (#29304)
add af23d08150fd CAMEL-26278: camel-hazelcast - the hazelcast-seda
consumer restores a transferred exchange only with transferExchange=true and
otherwise takes its body (#29310)
add 3bec2839cdb9 CAMEL-26620: camel-azure-eventgrid - add integration
tests on Floci AZ (#29239)
add fadef82e50b5 CAMEL-26684: Fix flaky GrpcRouteControlledReplyTypeTest
add f5eac07ace90 CAMEL-26619: camel-azure-servicebus - run the integration
tests on Floci AZ (#29247)
add e0b1085685b3 CAMEL-26675: camel-chaos - report accuracy (#29309)
add 09145be223b6 CAMEL-26381: Fix flaky ConsulMasterIT by using a
dedicated namespace per cluster IT
add 0b1e41c5c42c CAMEL-26676: camel-chaos - feedback while adding rules
(#29311)
add b3d24ca5206d CAMEL-26631: camel-sjms - Fix flaky
BatchConsumerReconnectTest
add 5f30ac0a9f3d CAMEL-26631: camel-test-infra-artemis - Make
embeddedBrokerService volatile
add 1a1cab52430b CAMEL-26677: camel-chaos - expectations on the error
handler (#29313)
add df119580f61b CAMEL-26685: camel-docker - imagepull/imagepush use the
endpoint auth only for its own registry (#29314)
add dca2a14b07c4 CAMEL-26680: camel-disruptor - multipleConsumers: each
consumer copies a snapshot of the exchange
add bc012bc516f5 CAMEL-26678: camel-chaos - live state of the rules
(#29318)
add f46eb9aca384 chore(deps): Bump com.aliyun:tea from 1.4.2 to 1.4.3 in
the aliyun group (#29316)
add 1c03245c3259 CAMEL-26337: camel-ftp, camel-mina-sftp,
camel-azure-files, camel-smb - refuse a readLock the component does not
implement (#29286)
add c19280fb3750 CAMEL-26630: design - exchange sanitizer: dev-mode checks
for exchanges completed twice, callbacks never called and consumer commits
(#29296)
add aad01013513d CAMEL-26666: Preserve Javadoc option descriptions
add 84d4521a694b CAMEL-26666: Regenerate catalog and DSL documentation
add fb7929a7433f CAMEL-26621: camel-azure-functions - run the integration
tests on Floci AZ (#29238)
add 2ca1885f9ae1 CAMEL-26687: camel-spring-ldap - the authenticate
operation fails fast when the password is missing or empty (#29321)
add 068189477671 CAMEL-26668: camel-mcp-server - error replies on /mcp are
JSON-RPC error responses (#29301)
add 7167a3dd3f05 CAMEL-26679: camel-chaos - new faults: error after the
send, timeout, jittered delay, start offset, bursts, flapping route, more
corrupt modes (#29322)
add 48d063cfde0a CAMEL-26379: camel-quartz - attempt to stabilize
QuartzCronRouteWithStartDateEndDateTest
add 18058a29443f CAMEL-26689: camel-chaos - a model of the chaos rules in
camel-catalog: targets, hooks, faults, parameters and known rules (#29331)
add fd88b01669c3 Merge remote-tracking branch 'origin/main' into
CAMEL-25334-payload-mode-design
No new revisions were added by this update.
Summary of changes:
.../check-container-versions.py | 537 ++++++-
.../test_check_container_versions.py | 779 +++++++++
.github/dependabot.yml | 3 +
.github/workflows/check-container-versions.yml | 13 +
.github/workflows/pr-ci-scripts-validation.yml | 5 +
AGENTS.md | 1 +
.../org/apache/camel/catalog/chaos-model.json | 1078 +++++++++++++
.../apache/camel/catalog/components/activemq.json | 8 +-
.../apache/camel/catalog/components/activemq6.json | 8 +-
.../catalog/components/alibaba-eventbridge.json | 2 +-
.../org/apache/camel/catalog/components/amqp.json | 8 +-
.../catalog/components/atmosphere-websocket.json | 2 +-
.../org/apache/camel/catalog/components/avro.json | 4 +-
.../catalog/components/aws-secrets-manager.json | 4 +-
.../apache/camel/catalog/components/aws2-ddb.json | 4 +-
.../catalog/components/aws2-kinesis-firehose.json | 2 +-
.../camel/catalog/components/aws2-kinesis.json | 6 +-
.../apache/camel/catalog/components/aws2-s3.json | 18 +-
.../apache/camel/catalog/components/aws2-sns.json | 8 +-
.../apache/camel/catalog/components/aws2-sqs.json | 13 +-
.../apache/camel/catalog/components/aws2-sts.json | 4 +-
.../camel/catalog/components/azure-files.json | 77 +-
.../camel/catalog/components/azure-servicebus.json | 4 +-
.../catalog/components/azure-storage-blob.json | 4 +-
.../apache/camel/catalog/components/coap+tcp.json | 2 +-
.../org/apache/camel/catalog/components/coap.json | 2 +-
.../apache/camel/catalog/components/coaps+tcp.json | 2 +-
.../org/apache/camel/catalog/components/coaps.json | 2 +-
.../apache/camel/catalog/components/couchbase.json | 10 +-
.../org/apache/camel/catalog/components/cql.json | 2 +-
.../org/apache/camel/catalog/components/cxf.json | 6 +-
.../org/apache/camel/catalog/components/cxfrs.json | 2 +-
.../camel/catalog/components/cyberark-vault.json | 50 +-
.../org/apache/camel/catalog/components/dapr.json | 82 +-
.../camel/catalog/components/debezium-db2.json | 350 ++--
.../camel/catalog/components/debezium-mongodb.json | 336 ++--
.../camel/catalog/components/debezium-mysql.json | 496 +++---
.../camel/catalog/components/debezium-oracle.json | 566 +++----
.../catalog/components/debezium-postgres.json | 470 +++---
.../catalog/components/debezium-sqlserver.json | 368 +++--
.../apache/camel/catalog/components/docker.json | 42 +-
.../apache/camel/catalog/components/docling.json | 4 +-
.../org/apache/camel/catalog/components/event.json | 2 +-
.../org/apache/camel/catalog/components/exec.json | 4 +-
.../org/apache/camel/catalog/components/fhir.json | 10 +-
.../camel/catalog/components/file-watch.json | 2 +-
.../org/apache/camel/catalog/components/file.json | 6 +-
.../org/apache/camel/catalog/components/ftp.json | 59 +-
.../org/apache/camel/catalog/components/ftps.json | 77 +-
.../camel/catalog/components/google-drive.json | 2 +-
.../catalog/components/google-mail-stream.json | 4 +-
.../camel/catalog/components/google-mail.json | 14 +-
.../catalog/components/google-sheets-stream.json | 4 +-
.../camel/catalog/components/google-sheets.json | 6 +-
.../camel/catalog/components/google-vertexai.json | 2 +-
.../org/apache/camel/catalog/components/grpc.json | 4 +-
.../camel/catalog/components/hashicorp-vault.json | 9 +-
.../catalog/components/hazelcast-instance.json | 2 +-
.../camel/catalog/components/hazelcast-list.json | 2 +-
.../camel/catalog/components/hazelcast-map.json | 2 +-
.../catalog/components/hazelcast-multimap.json | 2 +-
.../camel/catalog/components/hazelcast-queue.json | 2 +-
.../components/hazelcast-replicatedmap.json | 2 +-
.../camel/catalog/components/hazelcast-seda.json | 4 +-
.../camel/catalog/components/hazelcast-set.json | 2 +-
.../camel/catalog/components/hazelcast-topic.json | 2 +-
.../org/apache/camel/catalog/components/http.json | 6 +-
.../org/apache/camel/catalog/components/https.json | 6 +-
.../apache/camel/catalog/components/ibm-cos.json | 6 +-
.../org/apache/camel/catalog/components/jdbc.json | 8 +-
.../org/apache/camel/catalog/components/jetty.json | 2 +-
.../camel/catalog/components/jgroups-raft.json | 4 +-
.../apache/camel/catalog/components/jgroups.json | 8 +-
.../org/apache/camel/catalog/components/jms.json | 8 +-
.../org/apache/camel/catalog/components/jolt.json | 2 +-
.../apache/camel/catalog/components/jsonata.json | 2 +-
.../org/apache/camel/catalog/components/jt400.json | 4 +-
.../org/apache/camel/catalog/components/kafka.json | 12 +-
.../apache/camel/catalog/components/keycloak.json | 10 +-
.../catalog/components/kubernetes-events.json | 2 +-
.../catalog/components/langchain4j-agent.json | 4 +-
.../camel/catalog/components/langchain4j-chat.json | 4 +-
.../catalog/components/langchain4j-embeddings.json | 4 +-
.../org/apache/camel/catalog/components/llm.json | 8 +-
.../camel/catalog/components/micrometer.json | 2 +-
.../camel/catalog/components/milo-browse.json | 10 +-
.../camel/catalog/components/milo-client.json | 8 +-
.../apache/camel/catalog/components/mina-sftp.json | 101 +-
.../org/apache/camel/catalog/components/mina.json | 8 +-
.../org/apache/camel/catalog/components/minio.json | 24 +-
.../org/apache/camel/catalog/components/mllp.json | 6 +-
.../apache/camel/catalog/components/mongodb.json | 4 +-
.../org/apache/camel/catalog/components/nats.json | 12 +-
.../camel/catalog/components/netty-http.json | 4 +-
.../org/apache/camel/catalog/components/netty.json | 2 +-
.../apache/camel/catalog/components/oaipmh.json | 2 +-
.../org/apache/camel/catalog/components/opa.json | 28 +-
.../apache/camel/catalog/components/openai.json | 8 +-
.../apache/camel/catalog/components/openfga.json | 28 +-
.../catalog/components/opentelemetry-metrics.json | 2 +-
.../camel/catalog/components/paho-mqtt5.json | 4 +-
.../org/apache/camel/catalog/components/paho.json | 4 +-
.../org/apache/camel/catalog/components/pdf.json | 8 +-
.../apache/camel/catalog/components/pgvector.json | 4 +-
.../apache/camel/catalog/components/pinecone.json | 3 +-
.../camel/catalog/components/platform-http.json | 2 +-
.../org/apache/camel/catalog/components/pqc.json | 6 +-
.../apache/camel/catalog/components/pulsar.json | 8 +-
.../apache/camel/catalog/components/quickfix.json | 2 +-
.../camel/catalog/components/rest-openapi.json | 4 +-
.../camel/catalog/components/rest-postman.json | 4 +-
.../apache/camel/catalog/components/rocketmq.json | 12 +-
.../camel/catalog/components/salesforce.json | 4 +-
.../camel/catalog/components/sap-netweaver.json | 2 +-
.../org/apache/camel/catalog/components/scp.json | 4 +-
.../org/apache/camel/catalog/components/seda.json | 2 +-
.../apache/camel/catalog/components/servlet.json | 2 +-
.../org/apache/camel/catalog/components/sftp.json | 101 +-
.../org/apache/camel/catalog/components/sjms.json | 4 +-
.../org/apache/camel/catalog/components/sjms2.json | 4 +-
.../org/apache/camel/catalog/components/smb.json | 61 +-
.../org/apache/camel/catalog/components/smpp.json | 64 +-
.../org/apache/camel/catalog/components/smpps.json | 64 +-
.../apache/camel/catalog/components/spiffe.json | 4 +-
.../camel/catalog/components/splunk-hec.json | 2 +-
.../camel/catalog/components/spring-ai-chat.json | 2 +-
.../camel/catalog/components/spring-jdbc.json | 8 +-
.../camel/catalog/components/spring-redis.json | 2 +-
.../org/apache/camel/catalog/components/sql.json | 10 +-
.../org/apache/camel/catalog/components/ssh.json | 8 +-
.../org/apache/camel/catalog/components/stub.json | 2 +-
.../camel/catalog/components/typesafe-ai.json | 4 +-
.../apache/camel/catalog/components/undertow.json | 2 +-
.../camel/catalog/components/vertx-http.json | 4 +-
.../apache/camel/catalog/components/whatsapp.json | 9 +-
.../org/apache/camel/catalog/dataformats/avro.json | 2 +-
.../apache/camel/catalog/dataformats/base64.json | 2 +-
.../camel/catalog/dataformats/xmlSecurity.json | 2 +-
.../apache/camel/catalog/dev-consoles-openapi.json | 68 +-
.../apache/camel/catalog/dev-consoles/chaos.json | 68 +-
.../camel/catalog/docs/aws2-kinesis-component.adoc | 72 +-
.../camel/catalog/docs/aws2-s3-component.adoc | 16 +-
.../catalog/docs/aws2-s3-consumer-examples.adoc | 2 +-
.../camel/catalog/docs/aws2-sqs-component.adoc | 17 +
.../camel/catalog/docs/aws2-sts-component.adoc | 11 +
.../camel/catalog/docs/azure-files-component.adoc | 8 +
.../docs/azure-storage-datalake-component.adoc | 7 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 327 +++-
.../camel/catalog/docs/couchbase-component.adoc | 2 +-
.../apache/camel/catalog/docs/cql-component.adoc | 2 +-
.../catalog/docs/cyberark-vault-component.adoc | 25 +-
.../apache/camel/catalog/docs/dapr-component.adoc | 12 +
.../camel/catalog/docs/docker-component.adoc | 25 +
.../apache/camel/catalog/docs/ftp-component.adoc | 8 +
.../apache/camel/catalog/docs/ftps-component.adoc | 9 +
.../apache/camel/catalog/docs/git-component.adoc | 15 +
.../apache/camel/catalog/docs/grpc-component.adoc | 6 +-
.../catalog/docs/hashicorp-vault-component.adoc | 72 +-
.../catalog/docs/hazelcast-seda-component.adoc | 27 +
.../camel/catalog/docs/huggingface-component.adoc | 4 +-
.../apache/camel/catalog/docs/jdbc-component.adoc | 22 +-
.../camel/catalog/docs/keycloak-producer.adoc | 11 +
.../org/apache/camel/catalog/docs/main.adoc | 42 +-
.../org/apache/camel/catalog/docs/mcp-server.adoc | 60 +
.../camel/catalog/docs/micrometer-component.adoc | 5 +
.../camel/catalog/docs/mina-sftp-component.adoc | 27 +
.../camel/catalog/docs/mina-sftp-security.adoc | 48 +-
.../apache/camel/catalog/docs/neo4j-component.adoc | 1 +
.../docs/opentelemetry-metrics-component.adoc | 5 +
.../camel/catalog/docs/pinecone-component.adoc | 4 +
.../camel/catalog/docs/pqc-key-lifecycle.adoc | 45 +
.../apache/camel/catalog/docs/scp-component.adoc | 4 +
.../apache/camel/catalog/docs/sftp-component.adoc | 36 +
.../apache/camel/catalog/docs/smb-component.adoc | 17 +
.../org/apache/camel/catalog/docs/split-eip.adoc | 5 +
.../camel/catalog/docs/spring-ldap-component.adoc | 2 +
.../apache/camel/catalog/docs/ssh-component.adoc | 20 +
.../camel/catalog/docs/whatsapp-component.adoc | 9 +-
.../jbang/camel-jbang-configuration-metadata.json | 2 +-
.../main/camel-main-configuration-metadata.json | 38 +-
.../apache/camel/catalog/main/sensitive-keys.json | 3 +
.../org/apache/camel/catalog/models/avro.json | 2 +-
.../org/apache/camel/catalog/models/base64.json | 2 +-
.../org/apache/camel/catalog/models/kamelet.json | 2 +-
.../camel/catalog/models/redeliveryPolicy.json | 2 +-
.../apache/camel/catalog/models/removeHeaders.json | 2 +-
.../camel/catalog/models/removeProperties.json | 2 +-
.../apache/camel/catalog/models/xmlSecurity.json | 2 +-
.../apache/camel/catalog/schemas/camel-spring.xsd | 14 +-
.../apache/camel/catalog/schemas/camel-xml-io.xsd | 14 +-
.../camel/catalog/schemas/camelYamlDsl-model.json | 12 +-
.../apache/camel/catalog/test-infra/metadata.json | 621 ++++----
.../catalog/transformers/application-json.json | 6 +-
.../catalog/transformers/avro-x-java-object.json | 2 +-
.../camel/catalog/transformers/avro-x-struct.json | 3 +-
.../aws2-ddb-application-x-struct.json | 6 +-
.../camel/catalog/transformers/neo4j-rag.json | 2 +-
.../catalog/transformers/pinecone-embeddings.json | 2 +-
.../transformers/protobuf-x-java-object.json | 2 +-
.../org/apache/camel/catalog/CamelCatalog.java | 10 +
.../apache/camel/catalog/DefaultCamelCatalog.java | 5 +
.../org/apache/camel/catalog/CamelCatalogTest.java | 11 +
.../camel/catalog/DocExamplesXmlSchemaTest.java | 90 +-
.../apache/camel/component/activemq/activemq.json | 8 +-
.../camel/component/activemq6/activemq6.json | 8 +-
.../apache/camel/component/docling/docling.json | 4 +-
components/camel-ai/camel-huggingface/pom.xml | 6 +
.../src/main/docs/huggingface-component.adoc | 4 +-
.../huggingface/tasks/AbstractTaskPredictor.java | 14 +-
.../component/huggingface/tasks/ChatPredictor.java | 50 +-
.../huggingface/tasks/ChatHistoryTest.java | 129 +-
.../langchain4j/agent/langchain4j-agent.json | 4 +-
.../langchain4j/chat/langchain4j-chat.json | 4 +-
.../embeddings/langchain4j-embeddings.json | 4 +-
.../component/mcp/server/McpServerBridge.java | 8 +-
.../mcp/server/McpServerConfiguration.java | 20 +
.../camel/component/mcp/server/McpServerInfo.java | 21 +-
.../component/mcp/server/McpServerOrigins.java | 151 ++
.../component/mcp/server/McpServerBridgeTest.java | 44 +
.../component/mcp/server/McpServerOriginsTest.java | 95 ++
.../camel-mcp-server/src/main/docs/mcp-server.adoc | 60 +
.../mcp/server/main/DefaultMcpServerFactory.java | 1 +
.../mcp/server/vertx/VertxMcpServerEngine.java | 6 +-
.../VertxMcpStreamableServerTransportProvider.java | 137 +-
.../server/main/McpServerMainPropertiesTest.java | 62 +
.../server/vertx/VertxMcpErrorResponseTest.java | 146 ++
.../mcp/server/vertx/VertxMcpOriginTest.java | 301 ++++
.../MilvusEmbeddingsDataTypeTransformer.java | 5 +
.../MilvusEmbeddingsDataTypeTransformerTest.java | 24 +-
.../org/apache/camel/transformer/neo4j-rag.json | 2 +-
.../camel-neo4j/src/main/docs/neo4j-component.adoc | 1 +
.../Neo4jEmbeddingDataTypeTransformer.java | 5 +
.../Neo4jReverseEmbeddingsDataTypeTransformer.java | 24 +-
.../Neo4jEmbeddingDataTypeTransformerTest.java | 7 +-
...4jReverseEmbeddingsDataTypeTransformerTest.java | 24 +
.../org/apache/camel/component/openai/llm.json | 8 +-
.../org/apache/camel/component/openai/openai.json | 8 +-
.../apache/camel/component/pgvector/pgvector.json | 4 +-
.../apache/camel/component/pinecone/pinecone.json | 3 +-
.../camel/transformer/pinecone-embeddings.json | 2 +-
.../src/main/docs/pinecone-component.adoc | 4 +
.../pinecone/PineconeVectorDbHeaders.java | 6 +
.../pinecone/PineconeVectorDbProducer.java | 8 +-
.../PineconeEmbeddingsDataTypeTransformer.java | 28 +-
.../pinecone/PineconeVectorDbProducerTest.java | 83 +-
.../PineconeEmbeddingsDataTypeTransformerTest.java | 82 +-
.../QdrantEmbeddingsDataTypeTransformer.java | 5 +
.../QdrantEmbeddingsDataTypeTransformerTest.java | 7 +-
.../camel/component/typesafeai/typesafe-ai.json | 4 +-
.../WeaviateEmbeddingsDataTypeTransformer.java | 5 +
.../WeaviateEmbeddingsDataTypeTransformerTest.java | 18 +-
.../alibaba/eventbridge/alibaba-eventbridge.json | 2 +-
.../org/apache/camel/component/amqp/amqp.json | 8 +-
.../atmosphere/websocket/atmosphere-websocket.json | 2 +-
.../org/apache/camel/component/avro/avro.json | 4 +-
.../org/apache/camel/dataformat/avro/avro.json | 2 +-
.../aws/secretsmanager/aws-secrets-manager.json | 4 +-
.../vault/CloudTrailReloadTriggerTask.java | 61 +-
.../CloudTrailReloadTriggerTaskLookupTest.java | 99 +-
.../apache/camel/component/aws2/ddb/aws2-ddb.json | 4 +-
.../transformer/aws2-ddb-application-x-struct.json | 6 +-
.../Ddb2JsonStructDataTypeTransformer.java | 44 +-
.../Ddb2JsonStructDataTypeTransformerTest.java | 90 +-
.../aws2/firehose/aws2-kinesis-firehose.json | 2 +-
.../camel/component/aws2/kinesis/aws2-kinesis.json | 6 +-
.../src/main/docs/aws2-kinesis-component.adoc | 72 +-
.../aws2/kinesis/Kinesis2Configuration.java | 8 +-
.../component/aws2/kinesis/Kinesis2Producer.java | 141 +-
.../aws2/kinesis/Kinesis2ProducerTest.java | 196 +++
.../KinesisConsumerGetRecordsLimitTest.java | 143 ++
.../aws2/kinesis/KinesisEndpointTest.java | 2 +-
.../integration/KinesisConsumerResumeIT.java | 5 +
.../apache/camel/component/aws2/s3/aws2-s3.json | 18 +-
.../src/main/docs/aws2-s3-component.adoc | 16 +-
.../src/main/docs/aws2-s3-consumer-examples.adoc | 2 +-
.../component/aws2/s3/AWS2S3Configuration.java | 4 +-
.../camel/component/aws2/s3/AWS2S3Constants.java | 2 +-
.../camel/component/aws2/s3/AWS2S3Consumer.java | 279 ++--
.../camel/component/aws2/s3/AWS2S3Endpoint.java | 7 +-
.../camel/component/aws2/s3/AWS2S3Producer.java | 46 +-
.../camel/component/aws2/s3/utils/AWS2S3Utils.java | 35 +
.../aws2/s3/AWS2S3ConsumerDeletedObjectTest.java | 19 +-
.../aws2/s3/AWS2S3ConsumerGetEachObjectTest.java | 273 ++++
.../aws2/s3/AWS2S3ConsumerInProgressTest.java | 2 +
.../s3/AWS2S3ProducerGetObjectIgnoreBodyTest.java | 139 ++
.../camel/component/aws2/s3/FakeS3Server.java | 29 +-
.../component/aws2/s3/utils/AWS2S3UtilsTest.java | 49 +
.../apache/camel/component/aws2/sns/aws2-sns.json | 8 +-
.../apache/camel/component/aws2/sqs/aws2-sqs.json | 13 +-
.../src/main/docs/aws2-sqs-component.adoc | 17 +
.../camel/component/aws2/sqs/Sqs2Constants.java | 4 +
.../camel/component/aws2/sqs/Sqs2Consumer.java | 21 +
.../camel/component/aws2/sqs/Sqs2Endpoint.java | 12 +-
.../AWS2SQSCloudEventDataTypeTransformer.java | 7 +-
.../aws2/sqs/SqsComponentConfigurationTest.java | 14 +
.../sqs/SqsConsumerMaxMessagesPerPollTest.java | 111 ++
...2SQSCloudEventDataTypeTransformerRouteTest.java | 118 ++
.../AWS2SQSCloudEventDataTypeTransformerTest.java | 16 +-
.../apache/camel/component/aws2/sts/aws2-sts.json | 4 +-
.../src/main/docs/aws2-sts-component.adoc | 11 +
.../camel/component/aws2/sts/STS2Constants.java | 18 +-
.../camel/component/aws2/sts/STS2Producer.java | 9 +-
.../component/aws2/sts/AmazonSTSClientMock.java | 15 +-
.../camel/component/aws2/sts/STS2ProducerTest.java | 58 +
.../operations/CosmosDbDatabaseOperations.java | 4 +-
.../operations/CosmosDbDatabaseOperationsTest.java | 6 +
.../camel-azure/camel-azure-eventgrid/pom.xml | 15 +
.../eventgrid/integration/EventGridProducerIT.java | 151 ++
.../eventgrid/integration/EventGridSubscriber.java | 122 ++
.../src/test/resources/log4j2.properties | 3 +-
.../file/azure/FilesEndpointConfigurer.java | 18 -
.../file/azure/FilesEndpointUriFactory.java | 5 +-
.../camel/component/file/azure/azure-files.json | 77 +-
.../src/main/docs/azure-files-component.adoc | 8 +
.../camel/component/file/azure/FilesEndpoint.java | 1 +
.../file/azure/FilesEndpointReadLockTest.java | 77 +
.../camel-azure/camel-azure-functions/pom.xml | 12 +
.../integration/FunctionsProducerInvokeIT.java | 8 +-
.../integration/FunctionsProducerManagementIT.java | 136 +-
.../camel-azure/camel-azure-key-vault/pom.xml | 9 +
.../operations/KeyVaultOperationsIT.java | 168 ++
.../operations/KeyVaultOperationsTest.java | 110 --
.../camel-azure/camel-azure-servicebus/pom.xml | 9 +
.../azure/servicebus/azure-servicebus.json | 4 +-
.../integration/BaseServiceBusTestSupport.java | 56 +-
.../integration/ServiceBusConsumerIT.java | 28 +-
.../integration/ServiceBusProducerIT.java | 11 +-
...Test.java => ServiceBusSenderOperationsIT.java} | 21 +-
.../azure/storage/blob/azure-storage-blob.json | 4 +-
.../camel-azure-storage-datalake/pom.xml | 6 +
.../docs/azure-storage-datalake-component.adoc | 7 +-
.../operations/DataLakeFileOperations.java | 9 +-
.../azure/storage/datalake/integration/Base.java | 6 +-
.../datalake/integration/DataLakeConsumerIT.java | 5 -
.../integration/DataLakeFileOperationIT.java | 2 -
.../integration/DataLakeFileSystemOperationIT.java | 2 -
.../datalake/integration/DataLakeProducerIT.java | 4 -
.../operations/DataLakeFileOperationTest.java | 89 ++
.../org/apache/camel/dataformat/base64/base64.json | 2 +-
.../org/apache/camel/component/cassandra/cql.json | 2 +-
.../src/main/docs/cql-component.adoc | 2 +-
components/camel-chaos/pom.xml | 15 +
.../org/apache/camel/chaos/chaos-model.json | 1078 +++++++++++++
.../org/apache/camel/dev-console/chaos.json | 68 +-
components/camel-chaos/src/main/docs/chaos.adoc | 327 +++-
.../camel/component/chaos/ChaosDevConsole.java | 20 +-
.../camel/component/chaos/ChaosEventNotifier.java | 49 +-
.../camel/component/chaos/ChaosExchangeState.java | 212 +++
.../apache/camel/component/chaos/ChaosFaults.java | 209 ++-
.../camel/component/chaos/ChaosLifecycle.java | 101 +-
.../apache/camel/component/chaos/ChaosManager.java | 290 +++-
.../apache/camel/component/chaos/ChaosModel.java | 602 +++++++
.../camel/component/chaos/ChaosPollStrategy.java | 54 +-
.../camel/component/chaos/ChaosRecentFaults.java | 60 +
.../apache/camel/component/chaos/ChaosReport.java | 425 ++++-
.../component/chaos/ChaosRoutePolicyFactory.java | 7 +-
.../apache/camel/component/chaos/ChaosRule.java | 451 +++++-
.../camel/component/chaos/ChaosRuleParser.java | 316 +++-
.../camel/component/chaos/ChaosSendHook.java | 76 +-
.../camel/component/chaos/ChaosStepHook.java | 8 +-
.../apache/camel/component/chaos/ChaosTargets.java | 137 ++
.../chaos/ChaosErrorHandlerExpectationTest.java | 185 +++
.../camel/component/chaos/ChaosLifecycleTest.java | 86 +-
.../camel/component/chaos/ChaosLiveStateTest.java | 271 ++++
.../camel/component/chaos/ChaosModelTest.java | 188 +++
.../camel/component/chaos/ChaosPollFaultsTest.java | 8 +
.../component/chaos/ChaosReplyFaultsTest.java | 117 ++
.../camel/component/chaos/ChaosReportTest.java | 54 +-
.../component/chaos/ChaosRouteCountsTest.java | 62 +
.../component/chaos/ChaosRuleFeedbackTest.java | 140 ++
.../camel/component/chaos/ChaosRuleParserTest.java | 174 +-
.../camel/component/chaos/ChaosRuleTest.java | 42 +-
.../camel/component/chaos/ChaosSendFaultsTest.java | 65 +-
.../component/chaos/ChaosStartupClockTest.java | 107 ++
.../chaos/ChaosStepAndErrorHandlerTest.java | 64 +-
.../component/chaos/ChaosTimingFaultsTest.java | 167 ++
.../META-INF/org/apache/camel/coap/coap+tcp.json | 2 +-
.../META-INF/org/apache/camel/coap/coap.json | 2 +-
.../META-INF/org/apache/camel/coap/coaps+tcp.json | 2 +-
.../META-INF/org/apache/camel/coap/coaps.json | 2 +-
.../ConsulClusteredRoutePolicyFactoryIT.java | 11 +-
.../cluster/ConsulClusteredRoutePolicyIT.java | 12 +-
.../component/consul/cluster/ConsulMasterIT.java | 15 +-
.../camel/component/couchbase/couchbase.json | 10 +-
.../src/main/docs/couchbase-component.adoc | 2 +-
.../apache/camel/component/cxf/jaxrs/cxfrs.json | 2 +-
.../org/apache/camel/component/cxf/jaxws/cxf.json | 6 +-
.../camel/component/cxf/jaxws/CxfProducerTest.java | 28 +-
.../component/cyberark/vault/cyberark-vault.json | 50 +-
.../src/main/docs/cyberark-vault-component.adoc | 25 +-
.../cyberark/vault/CyberArkVaultConfiguration.java | 11 +-
.../cyberark/vault/CyberArkVaultEndpoint.java | 30 +-
.../cyberark/vault/CyberArkVaultProducer.java | 1 -
.../vault/CyberArkVaultPropertiesFunction.java | 13 +-
.../cyberark/vault/client/ConjurClientFactory.java | 152 ++
.../vault/client/impl/ConjurClientImpl.java | 54 +-
.../CyberArkVaultEndpointCredentialsTest.java | 122 ++
.../cyberark/vault/CyberArkVaultProducerTest.java | 108 ++
.../cyberark/vault/CyberArkVaultSslTest.java | 214 +++
.../impl/ConjurClientReauthenticationTest.java | 177 +++
.../client/impl/ConjurClientSecretVersionTest.java | 97 ++
.../vault/integration/CyberArkVaultProducerIT.java | 6 +-
.../component/cyberark/vault/ssl/conjur-server.p12 | Bin 0 -> 1028 bytes
.../component/cyberark/vault/ssl/conjur-server.pem | 10 +
.../component/dapr/DaprComponentConfigurer.java | 17 +
.../component/dapr/DaprEndpointConfigurer.java | 17 +
.../component/dapr/DaprEndpointUriFactory.java | 8 +-
.../org/apache/camel/component/dapr/dapr.json | 82 +-
.../camel-dapr/src/main/docs/dapr-component.adoc | 12 +
.../apache/camel/component/dapr/DaprComponent.java | 12 +
.../camel/component/dapr/DaprConfiguration.java | 37 +
.../dapr/DaprConfigurationOptionsProxy.java | 26 +-
.../apache/camel/component/dapr/DaprConstants.java | 13 +-
.../dapr/operations/DaprSecretHandler.java | 21 +-
.../dapr/DaprConfigurationOptionsProxyTest.java | 46 +
.../camel/component/dapr/DaprProducerTest.java | 117 ++
.../camel/maven/GenerateConnectorConfigMojo.java | 14 +-
.../maven/config/ConnectorConfigGenerator.java | 40 +
.../maven/config/ConnectorConfigGeneratorTest.java | 25 +
.../db2/DebeziumDb2ComponentConfigurer.java | 144 ++
.../db2/DebeziumDb2EndpointConfigurer.java | 144 ++
.../db2/DebeziumDb2EndpointUriFactory.java | 26 +-
.../Db2ConnectorEmbeddedDebeziumConfiguration.java | 1626 ++++++++++++-------
.../camel/component/debezium/db2/debezium-db2.json | 350 ++--
.../DebeziumMongodbComponentConfigurer.java | 90 ++
.../mongodb/DebeziumMongodbEndpointConfigurer.java | 90 ++
.../mongodb/DebeziumMongodbEndpointUriFactory.java | 17 +-
...goDbConnectorEmbeddedDebeziumConfiguration.java | 1309 +++++++++------
.../debezium/mongodb/debezium-mongodb.json | 336 ++--
.../camel-debezium/camel-debezium-mysql/pom.xml | 4 +
.../mysql/DebeziumMySqlComponentConfigurer.java | 78 +
.../mysql/DebeziumMySqlEndpointConfigurer.java | 78 +
.../mysql/DebeziumMySqlEndpointUriFactory.java | 15 +-
...ySqlConnectorEmbeddedDebeziumConfiguration.java | 420 +++--
.../component/debezium/mysql/debezium-mysql.json | 496 +++---
.../oracle/DebeziumOracleComponentConfigurer.java | 84 +
.../oracle/DebeziumOracleEndpointConfigurer.java | 84 +
.../oracle/DebeziumOracleEndpointUriFactory.java | 16 +-
...acleConnectorEmbeddedDebeziumConfiguration.java | 619 +++++---
.../component/debezium/oracle/debezium-oracle.json | 566 +++----
.../DebeziumPostgresComponentConfigurer.java | 72 +
.../DebeziumPostgresEndpointConfigurer.java | 72 +
.../DebeziumPostgresEndpointUriFactory.java | 14 +-
...gresConnectorEmbeddedDebeziumConfiguration.java | 506 ++++--
.../debezium/postgres/debezium-postgres.json | 470 +++---
.../DebeziumSqlserverComponentConfigurer.java | 78 +
.../DebeziumSqlserverEndpointConfigurer.java | 78 +
.../DebeziumSqlserverEndpointUriFactory.java | 15 +-
...rverConnectorEmbeddedDebeziumConfiguration.java | 1672 +++++++++++---------
.../debezium/sqlserver/debezium-sqlserver.json | 368 +++--
.../disruptor/AbstractSynchronizedExchange.java | 5 +
.../component/disruptor/DisruptorConsumer.java | 3 +-
.../MultipleConsumerSynchronizedExchange.java | 11 +
.../component/disruptor/SynchronizedExchange.java | 7 +
...DisruptorMultipleConsumersLateConsumerTest.java | 87 +
.../docker/DockerComponentConfigurer.java | 6 +
.../component/docker/DockerEndpointConfigurer.java | 6 +
.../component/docker/DockerEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/docker/docker.json | 42 +-
.../src/main/docs/docker-component.adoc | 25 +
.../component/docker/DockerClientFactory.java | 40 +-
.../component/docker/DockerConfiguration.java | 18 +
.../camel/component/docker/DockerConstants.java | 41 +-
.../camel/component/docker/DockerHelper.java | 59 +
.../docker/producer/AsyncDockerProducer.java | 35 +-
.../component/docker/DockerClientFactoryTest.java | 225 +++
.../camel/component/docker/DockerHelperTest.java | 34 +
.../docker/headers/AuthCmdHeaderTest.java | 6 +
.../docker/headers/BaseDockerHeaderTest.java | 31 +-
.../docker/headers/PullImageCmdHeaderTest.java | 16 +
...Test.java => PullImageCmdRegistryAuthTest.java} | 65 +-
.../docker/headers/PushImageCmdHeaderTest.java | 44 +
.../ElasticsearchActionRequestConverter.java | 9 +-
.../ElasticsearchActionRequestConverterTest.java | 12 +
.../apache/camel/component/camelevent/event.json | 2 +-
.../org/apache/camel/component/exec/exec.json | 4 +-
.../fhir/FhirCreateEndpointConfiguration.java | 2 +-
.../fhir/FhirDeleteEndpointConfiguration.java | 2 +-
.../fhir/FhirHistoryEndpointConfiguration.java | 2 +-
.../fhir/FhirPatchEndpointConfiguration.java | 2 +-
.../fhir/FhirSearchEndpointConfiguration.java | 2 +-
.../org/apache/camel/component/fhir/fhir.json | 10 +-
.../camel/component/file/watch/file-watch.json | 2 +-
.../org/apache/camel/component/file/file.json | 6 +-
.../apache/camel/component/file/FileComponent.java | 2 +
.../apache/camel/component/file/FileConsumer.java | 103 +-
.../camel/component/file/GenericFileConsumer.java | 18 +-
.../camel/component/file/GenericFileEndpoint.java | 4 +-
.../component/file/GenericFileKeptDoneFiles.java | 53 +-
.../file/GenericFileListingOperations.java | 47 +
.../component/file/GenericFileOnCompletion.java | 8 +-
.../file/FileComponentPathSeparatorTest.java | 86 +
.../file/GenericFileKeptDoneFilesTest.java | 22 +
.../file/remote/AbstractSftpConsumer.java | 181 ++-
.../component/file/remote/RemoteFileEndpoint.java | 48 +
components/camel-ftp/pom.xml | 9 +
.../file/remote/FtpEndpointConfigurer.java | 18 -
.../file/remote/FtpEndpointUriFactory.java | 5 +-
.../file/remote/FtpsEndpointUriFactory.java | 5 +-
.../file/remote/SftpEndpointConfigurer.java | 42 -
.../file/remote/SftpEndpointUriFactory.java | 9 +-
.../apache/camel/component/file/remote/ftp.json | 59 +-
.../apache/camel/component/file/remote/ftps.json | 77 +-
.../apache/camel/component/file/remote/sftp.json | 101 +-
.../camel-ftp/src/main/docs/ftp-component.adoc | 8 +
.../camel-ftp/src/main/docs/ftps-component.adoc | 9 +
.../camel-ftp/src/main/docs/sftp-component.adoc | 36 +
.../camel/component/file/remote/FtpEndpoint.java | 1 +
.../camel/component/file/remote/FtpsEndpoint.java | 1 +
.../camel/component/file/remote/SftpEndpoint.java | 3 +
.../component/file/remote/SftpOperations.java | 42 +-
.../remote/RemoteFileEndpointReadLockTest.java | 184 +++
.../SftpConsumerMaxMessagesPerPollListingIT.java | 246 +++
.../integration/SftpPostQuantumKeyExchangeIT.java | 61 +
.../camel-git/src/main/docs/git-component.adoc | 15 +
.../apache/camel/component/git/GitEndpoint.java | 4 +-
.../git/consumer/AbstractGitConsumer.java | 65 +-
.../component/git/consumer/GitBranchConsumer.java | 3 +-
.../component/git/consumer/GitCommitConsumer.java | 3 +-
.../component/git/consumer/GitTagConsumer.java | 3 +-
.../GitConsumerFailedItemPooledExchangeTest.java} | 21 +-
.../git/consumer/GitConsumerFailedItemTest.java | 216 +++
.../git/consumer/GitConsumerFirstPollTest.java | 129 ++
.../git/consumer/GitConsumerOptionsTest.java | 92 ++
.../git/consumer/RecordingExceptionHandler.java | 57 +
...alendarStreamCloudEventDataTypeTransformer.java | 14 +-
...darStreamCloudEventDataTypeTransformerTest.java | 33 +-
.../drive/DriveFilesEndpointConfiguration.java | 2 +-
.../camel/component/google/drive/google-drive.json | 2 +-
.../GmailUsersDraftsEndpointConfiguration.java | 2 +-
.../mail/GmailUsersEndpointConfiguration.java | 2 +-
.../GmailUsersHistoryEndpointConfiguration.java | 2 +-
.../GmailUsersLabelsEndpointConfiguration.java | 2 +-
...rsMessagesAttachmentsEndpointConfiguration.java | 2 +-
.../GmailUsersMessagesEndpointConfiguration.java | 2 +-
.../GmailUsersThreadsEndpointConfiguration.java | 2 +-
.../camel/component/google/mail/google-mail.json | 14 +-
.../google/mail/stream/google-mail-stream.json | 4 +-
...etsSpreadsheetsValuesEndpointConfiguration.java | 4 +-
.../component/google/sheets/google-sheets.json | 6 +-
.../google/sheets/stream/google-sheets-stream.json | 4 +-
.../component/google/vertexai/google-vertexai.json | 2 +-
.../groovy/DefaultGroovyScriptCompiler.java | 2 +-
.../camel/language/groovy/GroovyExpression.java | 11 +-
.../camel/language/groovy/GroovyLanguage.java | 65 +-
.../groovy/GroovyCompilePreProcessorTest.java | 40 +
.../groovy/GroovyMissingPropertyHintTest.java | 14 +
.../org/apache/camel/component/grpc/grpc.json | 4 +-
.../camel-grpc/src/main/docs/grpc-component.adoc | 6 +-
.../camel/component/grpc/GrpcConfiguration.java | 4 +-
.../GrpcRequestPropagationStreamObserver.java | 46 +-
.../grpc/GrpcPropagationRouteControlledTest.java | 178 +++
.../grpc/GrpcRouteControlledReplyTypeTest.java | 28 +
.../vault/HashicorpVaultEndpointConfigurer.java | 33 +
.../vault/HashicorpVaultEndpointUriFactory.java | 14 +-
.../component/hashicorp/vault/hashicorp-vault.json | 9 +-
.../src/main/docs/hashicorp-vault-component.adoc | 72 +-
.../vault/HashicorpVaultAuthentication.java | 70 +
.../hashicorp/vault/HashicorpVaultClient.java | 251 +++
.../vault/HashicorpVaultClientSettings.java | 222 +++
.../hashicorp/vault/HashicorpVaultComponent.java | 7 +-
.../vault/HashicorpVaultConfiguration.java | 99 +-
.../hashicorp/vault/HashicorpVaultEndpoint.java | 52 +-
.../vault/HashicorpVaultPropertiesFunction.java | 99 +-
.../hashicorp/vault/SecretsDevConsole.java | 13 +-
.../vault/HashicorpVaultReloadTriggerTask.java | 74 +-
.../camel/component/hashicorp/vault/FakeVault.java | 147 ++
.../vault/HashicorpVaultClientSettingsTest.java | 124 ++
.../hashicorp/vault/HashicorpVaultClientTest.java | 329 ++++
.../hashicorp/vault/HashicorpVaultLoginTest.java | 104 ++
.../HashicorpVaultPropertiesFunctionTest.java | 17 +
.../hashicorp/vault/SecretsDevConsoleTest.java | 13 +-
.../vault/integration/HashicorpVaultLoginIT.java | 181 +++
.../hazelcast/instance/hazelcast-instance.json | 2 +-
.../component/hazelcast/list/hazelcast-list.json | 2 +-
.../component/hazelcast/map/hazelcast-map.json | 2 +-
.../hazelcast/multimap/hazelcast-multimap.json | 2 +-
.../component/hazelcast/queue/hazelcast-queue.json | 2 +-
.../replicatedmap/hazelcast-replicatedmap.json | 2 +-
.../component/hazelcast/seda/hazelcast-seda.json | 4 +-
.../component/hazelcast/set/hazelcast-set.json | 2 +-
.../component/hazelcast/topic/hazelcast-topic.json | 2 +-
.../src/main/docs/hazelcast-seda-component.adoc | 27 +
.../hazelcast/seda/HazelcastSedaConfiguration.java | 3 +-
.../hazelcast/seda/HazelcastSedaConsumer.java | 27 +-
.../hazelcast/seda/HazelcastSedaEndpoint.java | 5 +-
.../hazelcast/HazelcastAggregationRepository.java | 32 +-
.../HazelcastReliableTopicConsumerLossTest.java | 11 +-
.../HazelcastSedaTransferExchangeTest.java | 80 +-
...zelcastAggregationRepositoryOperationsTest.java | 86 +
.../org/apache/camel/component/http/http.json | 6 +-
.../org/apache/camel/component/http/https.json | 6 +-
.../apache/camel/component/ibm/cos/ibm-cos.json | 6 +-
.../camel/transformer/avro-x-java-object.json | 2 +-
.../apache/camel/transformer/avro-x-struct.json | 3 +-
.../transform/AvroPojoDataTypeTransformer.java | 14 +-
.../transform/AvroStructDataTypeTransformer.java | 10 +-
.../transform/AvroPojoDataTypeTransformerTest.java | 37 +-
.../AvroStructDataTypeTransformerTest.java | 46 +-
.../camel/transformer/protobuf-x-java-object.json | 2 +-
.../transform/ProtobufPojoDataTypeTransformer.java | 9 +-
.../ProtobufStructDataTypeTransformer.java | 2 +-
.../ProtobufPojoDataTypeTransformerTest.java | 37 +-
.../ProtobufStructDataTypeTransformerTest.java | 16 +
.../apache/camel/transformer/application-json.json | 6 +-
.../jackson/transform/JsonDataTypeTransformer.java | 44 +-
.../transform/JsonPojoDataTypeTransformer.java | 2 +-
.../transform/JsonDataTypeTransformerTest.java | 125 +-
.../transform/JsonPojoDataTypeTransformerTest.java | 14 +
.../camel/transformer/avro-x-java-object.json | 2 +-
.../apache/camel/transformer/avro-x-struct.json | 3 +-
.../transform/AvroBinaryDataTypeTransformer.java | 3 +-
.../transform/AvroPojoDataTypeTransformer.java | 9 +-
.../transform/AvroStructDataTypeTransformer.java | 13 +-
.../AvroBinaryDataTypeTransformerTest.java | 12 +
.../transform/AvroPojoDataTypeTransformerTest.java | 37 +-
.../AvroStructDataTypeTransformerTest.java | 53 +-
.../camel/transformer/protobuf-x-java-object.json | 2 +-
.../ProtobufBinaryDataTypeTransformer.java | 3 +-
.../transform/ProtobufPojoDataTypeTransformer.java | 4 +-
.../ProtobufStructDataTypeTransformer.java | 5 +-
.../ProtobufBinaryDataTypeTransformerTest.java | 12 +
.../ProtobufPojoDataTypeTransformerTest.java | 37 +-
.../ProtobufStructDataTypeTransformerTest.java | 28 +
.../apache/camel/transformer/application-json.json | 6 +-
.../transform/JsonDataTypeTransformer.java | 44 +-
.../transform/JsonPojoDataTypeTransformer.java | 2 +-
.../transform/JsonDataTypeTransformerTest.java | 125 +-
.../transform/JsonPojoDataTypeTransformerTest.java | 14 +
.../org/apache/camel/component/jdbc/jdbc.json | 8 +-
.../camel-jdbc/src/main/docs/jdbc-component.adoc | 22 +-
.../jdbc/DefaultJdbcPrepareStatementStrategy.java | 62 +-
.../apache/camel/component/jdbc/JdbcConstants.java | 8 +-
.../apache/camel/component/jdbc/JdbcEndpoint.java | 9 +-
.../component/jdbc/JdbcParameterizedQueryTest.java | 176 ++-
.../org/apache/camel/component/jetty12/jetty.json | 2 +-
.../jetty/JettyHttpEndpointDisconnectTest.java | 45 +-
.../src/test/resources/log4j2.properties | 2 +
.../camel/component/jgroups/raft/jgroups-raft.json | 4 +-
.../apache/camel/component/jgroups/jgroups.json | 8 +-
.../org/apache/camel/component/jms/jms.json | 8 +-
.../org/apache/camel/component/jolt/jolt.json | 2 +-
.../org/apache/camel/component/scp/scp.json | 4 +-
.../camel-jsch/src/main/docs/scp-component.adoc | 4 +
.../apache/camel/component/scp/ScpOperations.java | 22 +
.../component/scp/ScpFileNameControlCharTest.java | 154 ++
.../apache/camel/component/jsonata/jsonata.json | 2 +-
.../org/apache/camel/component/jt400/jt400.json | 4 +-
.../org/apache/camel/component/kafka/kafka.json | 12 +-
.../camel/component/kafka/KafkaFetchRecords.java | 10 +-
.../KafkaConsumerBreakOnFirstErrorPausedTest.java | 382 +++++
.../camel/component/kamelet/KameletComponent.java | 81 +-
.../kamelet/KameletRouteRemovalBusyPoolTest.java | 147 ++
.../keycloak/KeycloakComponentConfigurer.java | 6 +
.../keycloak/KeycloakEndpointConfigurer.java | 6 +
.../keycloak/KeycloakEndpointUriFactory.java | 3 +-
.../apache/camel/component/keycloak/keycloak.json | 10 +-
.../src/main/docs/keycloak-producer.adoc | 11 +
.../component/keycloak/KeycloakConfiguration.java | 27 +-
.../component/keycloak/KeycloakConstants.java | 5 +-
.../camel/component/keycloak/KeycloakEndpoint.java | 5 +-
.../camel/component/keycloak/KeycloakProducer.java | 15 +-
.../KeycloakProducerOperationHeaderTest.java | 148 ++
.../kubernetes/events/kubernetes-events.json | 2 +-
.../KubernetesCustomResourcesProducer.java | 8 +-
.../KubernetesCustomResourcesProducerTest.java | 21 +
.../apache/camel/component/mail/MailConsumer.java | 10 +-
.../MailIdempotentRepositoryPollErrorTest.java | 37 +-
.../camel/component/micrometer/micrometer.json | 2 +-
.../src/main/docs/micrometer-component.adoc | 5 +
.../micrometer/AbstractMicrometerProducer.java | 4 +-
.../component/micrometer/MicrometerConstants.java | 4 +-
.../component/micrometer/CounterRouteTest.java | 38 +
.../camel/component/milo/browse/milo-browse.json | 10 +-
.../camel/component/milo/client/milo-client.json | 8 +-
components/camel-mina-sftp/pom.xml | 9 +
.../remote/mina/MinaSftpEndpointConfigurer.java | 42 -
.../remote/mina/MinaSftpEndpointUriFactory.java | 9 +-
.../component/file/remote/mina/mina-sftp.json | 101 +-
.../src/main/docs/mina-sftp-component.adoc | 27 +
.../src/main/docs/mina-sftp-security.adoc | 48 +-
.../file/remote/mina/MinaSftpEndpoint.java | 3 +
.../file/remote/mina/MinaSftpOperations.java | 39 +-
.../remote/mina/MinaSftpEndpointReadLockTest.java | 119 ++
...inaSftpConsumerMaxMessagesPerPollListingIT.java | 224 +++
.../mina/integration/MinaSftpTcpNoDelayIT.java | 62 +
.../mina/sftp/SftpKeyExchangeProtocolsIT.java | 18 +
.../org/apache/camel/component/mina/mina.json | 8 +-
.../org/apache/camel/component/minio/minio.json | 24 +-
.../org/apache/camel/component/mllp/mllp.json | 6 +-
.../apache/camel/component/mongodb/mongodb.json | 4 +-
.../mongodb/MongoAbstractConsumerThread.java | 23 +-
.../MongoDbConsumerCursorRegenerationTest.java | 65 +
.../org/apache/camel/component/nats/nats.json | 12 +-
.../camel/component/netty/http/netty-http.json | 4 +-
.../org/apache/camel/component/netty/netty.json | 2 +-
.../org/apache/camel/oaipmh/component/oaipmh.json | 2 +-
.../org/apache/camel/component/opa/opa.json | 28 +-
.../apache/camel/component/openfga/openfga.json | 28 +-
.../metrics/opentelemetry-metrics.json | 2 +-
.../main/docs/opentelemetry-metrics-component.adoc | 5 +
.../metrics/AbstractOpenTelemetryProducer.java | 17 +-
.../metrics/OpenTelemetryConstants.java | 3 +-
.../opentelemetry/metrics/CounterRouteTest.java | 38 +
.../camel/component/paho/mqtt5/paho-mqtt5.json | 4 +-
.../org/apache/camel/component/paho/paho.json | 4 +-
.../org/apache/camel/component/pdf/pdf.json | 8 +-
.../http/vertx/VertxPlatformHttpServer.java | 26 +-
.../VertxPlatformHttpServerPortInUseTest.java | 67 +
.../component/platform/http/platform-http.json | 2 +-
.../component/pqc/PQCComponentConfigurer.java | 6 +
.../camel/component/pqc/PQCEndpointConfigurer.java | 6 +
.../camel/component/pqc/PQCEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/pqc/pqc.json | 6 +-
.../camel-pqc/src/main/docs/pqc-key-lifecycle.adoc | 45 +
.../camel/component/pqc/PQCConfiguration.java | 23 +
.../apache/camel/component/pqc/PQCProducer.java | 173 +-
.../component/pqc/PQCSymmetricAlgorithms.java | 23 +
.../component/pqc/crypto/hybrid/HybridKEM.java | 8 +-
.../component/pqc/dataformat/PQCDataFormat.java | 18 +-
.../lifecycle/FileBasedKeyLifecycleManager.java | 186 +++
.../pqc/lifecycle/InMemoryKeyLifecycleManager.java | 9 +
.../pqc/lifecycle/KeyLifecycleManager.java | 33 +
.../component/pqc/PQCStatefulKeyAdoptionTest.java | 153 ++
.../component/pqc/PQCStatefulKeyClaimTest.java | 148 ++
.../pqc/crypto/hybrid/HybridKEMKeyLabelTest.java | 137 ++
...eBasedKeyLifecycleManagerStatefulClaimTest.java | 223 +++
.../org/apache/camel/component/pulsar/pulsar.json | 8 +-
.../QuartzCronRouteWithStartDateEndDateTest.java | 24 +-
.../apache/camel/component/quickfixj/quickfix.json | 2 +-
.../camel/component/rest/openapi/rest-openapi.json | 4 +-
.../camel/component/rest/postman/rest-postman.json | 4 +-
.../apache/camel/component/rocketmq/rocketmq.json | 12 +-
.../camel/component/salesforce/salesforce.json | 4 +-
.../component/sap/netweaver/sap-netweaver.json | 2 +-
.../org/apache/camel/component/seda/seda.json | 2 +-
.../apache/camel/component/servlet/servlet.json | 2 +-
.../org/apache/camel/component/sjms/sjms.json | 4 +-
.../sjms/batch/BatchConsumerReconnectTest.java | 25 +-
.../org/apache/camel/component/sjms2/sjms2.json | 4 +-
.../camel/component/smb/SmbEndpointConfigurer.java | 18 -
.../camel/component/smb/SmbEndpointUriFactory.java | 5 +-
.../org/apache/camel/component/smb/smb.json | 61 +-
.../camel-smb/src/main/docs/smb-component.adoc | 17 +
.../apache/camel/component/smb/SmbConsumer.java | 65 +-
.../apache/camel/component/smb/SmbEndpoint.java | 32 +-
.../apache/camel/component/smb/SmbOperations.java | 51 +
.../SmbConsumerMaxMessagesPerPollListingIT.java | 123 ++
.../component/smb/SmbEndpointReadLockTest.java | 45 +
.../org/apache/camel/component/smpp/smpp.json | 64 +-
.../org/apache/camel/component/smpp/smpps.json | 64 +-
.../org/apache/camel/component/spiffe/spiffe.json | 4 +-
.../camel/component/splunkhec/splunk-hec.json | 2 +-
.../component/springai/chat/spring-ai-chat.json | 2 +-
.../camel/component/spring/jdbc/spring-jdbc.json | 8 +-
.../component/spring/jdbc/SpringJdbcEndpoint.java | 5 +-
.../src/main/docs/spring-ldap-component.adoc | 2 +
.../component/springldap/SpringLdapProducer.java | 14 +-
.../springldap/SpringLdapProducerTest.java | 35 +
.../apache/camel/component/redis/spring-redis.json | 2 +-
.../org/apache/camel/component/sql/sql.json | 10 +-
.../org/apache/camel/component/ssh/ssh.json | 8 +-
.../camel-ssh/src/main/docs/ssh-component.adoc | 20 +
.../org/apache/camel/component/stub/stub.json | 2 +-
.../apache/camel/component/undertow/undertow.json | 2 +-
.../undertow/UndertowHandlersSpringTest.java | 13 +-
.../undertow/UndertowHttpsSpringTest.java | 12 +-
.../src/test/resources/HandlersSpringTest.xml | 11 +-
.../src/test/resources/SpringTest.xml | 11 +-
.../src/test/resources/spring.properties | 7 +-
.../camel/component/vertx/http/vertx-http.json | 4 +-
.../whatsapp/WhatsAppEndpointConfigurer.java | 6 +
.../whatsapp/WhatsAppEndpointUriFactory.java | 3 +-
.../apache/camel/component/whatsapp/whatsapp.json | 9 +-
.../src/main/docs/whatsapp-component.adoc | 9 +-
.../component/whatsapp/WhatsAppConfiguration.java | 20 +-
.../camel/component/whatsapp/WhatsAppEndpoint.java | 20 +-
.../whatsapp/WhatsAppWebhookProcessor.java | 24 +-
.../whatsapp/WhatsAppWebhookProcessorTest.java | 139 +-
.../whatsapp/WhatsAppWebhookStartupTest.java | 99 ++
.../component/whatsapp/WhatsAppWebhookTest.java | 47 +-
.../camel/dataformat/xmlsecurity/xmlSecurity.json | 2 +-
.../component/xmpp/XmppGroupChatProducer.java | 83 +-
.../component/xmpp/XmppPrivateChatProducer.java | 7 +-
.../camel/component/xmpp/FakeXmppServer.java | 20 +-
.../component/xmpp/XmppProducerReconnectTest.java | 248 +++
.../java/org/apache/camel/ExchangeExtension.java | 17 +
.../camel/vault/HashicorpVaultConfiguration.java | 136 +-
.../camel/impl/engine/AbstractCamelContext.java | 11 +-
.../camel/impl/engine/CamelInternalProcessor.java | 13 +-
.../camel/impl/engine/DefaultUnitOfWork.java | 87 +-
.../impl/engine/InternalRouteStartupManager.java | 4 +-
.../main/docs/modules/eips/pages/split-eip.adoc | 5 +
.../camel/language/simple/BaseSimpleParser.java | 4 +-
.../camel/language/simple/SimpleSyntaxHints.java | 76 +
.../org/apache/camel/model/dataformat/avro.json | 2 +-
.../org/apache/camel/model/dataformat/base64.json | 2 +-
.../apache/camel/model/dataformat/xmlSecurity.json | 2 +-
.../META-INF/org/apache/camel/model/kamelet.json | 2 +-
.../org/apache/camel/model/redeliveryPolicy.json | 2 +-
.../org/apache/camel/model/removeHeaders.json | 2 +-
.../org/apache/camel/model/removeProperties.json | 2 +-
.../apache/camel/processor/MulticastProcessor.java | 31 +-
.../RebalancingClusterServiceReleaseViewTest.java | 233 +++
.../FileConsumeMaxMessagesPerPollListingTest.java | 156 ++
.../FileConsumerDoneFileNameAsyncLastFileTest.java | 134 ++
.../RouteStartApplicationClassLoaderTest.java | 197 +++
.../language/simple/SimpleSyntaxHintsTest.java | 27 +
.../processor/MulticastOnCompletionThrowsTest.java | 406 +++++
.../RecipientListProducerThrowsInDoTryTest.java | 287 ++++
.../processor/ShareUnitOfWorkSedaHandoverTest.java | 319 ++++
.../SplitParallelShareUnitOfWorkHandoverTest.java | 212 +++
.../support/RouteWatcherReloadDataDirTest.java | 28 +
.../HashicorpVaultConfigurationConfigurer.java | 33 +
...corpVaultConfigurationPropertiesConfigurer.java | 40 +
...ttpServerConfigurationPropertiesConfigurer.java | 7 +
.../camel-main-configuration-metadata.json | 38 +-
core/camel-main/src/main/docs/main.adoc | 42 +-
.../HashicorpVaultConfigurationProperties.java | 56 +
.../main/HttpServerConfigurationProperties.java | 28 +
.../org/apache/camel/support/AbstractExchange.java | 68 +-
.../org/apache/camel/support/UnitOfWorkHelper.java | 71 +-
.../cluster/AbstractCamelClusterService.java | 29 +
.../cluster/RebalancingCamelClusterService.java | 93 +-
.../java/org/apache/camel/util/SecurityUtils.java | 14 +
.../java/org/apache/camel/util/SensitiveUtils.java | 6 +
.../org/apache/camel/util/SensitiveUtilsTest.java | 5 +
design/exchange-sanitizer.adoc | 783 +++++++++
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 76 +
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 93 ++
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 630 +++++++-
.../modules/ROOT/pages/camel-catalog.adoc | 9 +
.../ROOT/pages/camel-jbang-configuration.adoc | 2 +-
.../modules/ROOT/pages/camel-jbang-mcp.adoc | 19 +-
.../modules/ROOT/pages/camel-jbang-running.adoc | 4 +
.../jbang-commands/camel-jbang-cmd-chaos-add.adoc | 4 +-
.../camel-jbang-cmd-chaos-clear.adoc | 1 +
.../ROOT/pages/jbang-commands/camel-jbang-cmd.adoc | 2 +-
.../jbang-commands/camel-jbang-get-chaos.adoc | 2 +-
docs/user-manual/modules/ROOT/pages/security.adoc | 16 +
.../apache/camel/cli/connector/ChaosAction.java | 34 +-
.../LocalCliConnectorChaosActionTest.java | 38 +-
.../component/ComponentsBuilderFactory.java | 4 +-
.../dsl/Activemq6ComponentBuilderFactory.java | 8 +-
.../dsl/ActivemqComponentBuilderFactory.java | 8 +-
.../component/dsl/AmqpComponentBuilderFactory.java | 8 +-
...AtmosphereWebsocketComponentBuilderFactory.java | 4 +-
.../component/dsl/AvroComponentBuilderFactory.java | 2 +-
.../dsl/Aws2KinesisComponentBuilderFactory.java | 6 +-
.../dsl/Aws2S3ComponentBuilderFactory.java | 5 +-
.../dsl/Aws2SnsComponentBuilderFactory.java | 10 +-
.../dsl/Aws2SqsComponentBuilderFactory.java | 10 +-
.../AwsSecretsManagerComponentBuilderFactory.java | 2 +-
.../AzureServicebusComponentBuilderFactory.java | 2 +-
.../dsl/CouchbaseComponentBuilderFactory.java | 7 +-
.../component/dsl/CqlComponentBuilderFactory.java | 4 +-
.../dsl/CyberarkVaultComponentBuilderFactory.java | 74 +-
.../component/dsl/DaprComponentBuilderFactory.java | 44 +
.../dsl/DebeziumDb2ComponentBuilderFactory.java | 504 +++++-
.../DebeziumMongodbComponentBuilderFactory.java | 330 +++-
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 292 +++-
.../dsl/DebeziumOracleComponentBuilderFactory.java | 307 +++-
.../DebeziumPostgresComponentBuilderFactory.java | 267 +++-
.../DebeziumSqlserverComponentBuilderFactory.java | 279 +++-
.../dsl/DockerComponentBuilderFactory.java | 26 +
.../dsl/DoclingComponentBuilderFactory.java | 2 +-
.../component/dsl/ExecComponentBuilderFactory.java | 4 +-
.../GoogleMailStreamComponentBuilderFactory.java | 2 +-
.../dsl/GoogleSheetsComponentBuilderFactory.java | 2 +-
.../GoogleSheetsStreamComponentBuilderFactory.java | 2 +-
.../component/dsl/HttpComponentBuilderFactory.java | 6 +-
.../dsl/HttpsComponentBuilderFactory.java | 6 +-
.../dsl/JettyComponentBuilderFactory.java | 4 +-
.../dsl/JgroupsComponentBuilderFactory.java | 6 +-
.../component/dsl/JmsComponentBuilderFactory.java | 8 +-
.../dsl/KafkaComponentBuilderFactory.java | 20 +-
.../dsl/KeycloakComponentBuilderFactory.java | 23 +
.../Langchain4jAgentComponentBuilderFactory.java | 2 +-
.../Langchain4jChatComponentBuilderFactory.java | 4 +-
...ngchain4jEmbeddingsComponentBuilderFactory.java | 2 +-
.../dsl/MiloBrowseComponentBuilderFactory.java | 4 +-
.../dsl/MiloClientComponentBuilderFactory.java | 4 +-
.../component/dsl/MinaComponentBuilderFactory.java | 12 +-
.../component/dsl/MllpComponentBuilderFactory.java | 10 +-
.../component/dsl/NatsComponentBuilderFactory.java | 9 +-
.../component/dsl/OpaComponentBuilderFactory.java | 49 +-
.../dsl/OpenfgaComponentBuilderFactory.java | 49 +-
.../component/dsl/PahoComponentBuilderFactory.java | 4 +-
.../dsl/PahoMqtt5ComponentBuilderFactory.java | 4 +-
.../component/dsl/PqcComponentBuilderFactory.java | 23 +
.../dsl/PulsarComponentBuilderFactory.java | 6 +-
.../dsl/RestOpenapiComponentBuilderFactory.java | 2 +-
.../dsl/RestPostmanComponentBuilderFactory.java | 4 +-
.../dsl/RocketmqComponentBuilderFactory.java | 9 +-
.../dsl/SalesforceComponentBuilderFactory.java | 2 +-
.../dsl/ServletComponentBuilderFactory.java | 4 +-
.../dsl/Sjms2ComponentBuilderFactory.java | 6 +-
.../component/dsl/SjmsComponentBuilderFactory.java | 6 +-
.../dsl/SpiffeComponentBuilderFactory.java | 6 +-
.../component/dsl/SqlComponentBuilderFactory.java | 3 +-
.../component/dsl/SshComponentBuilderFactory.java | 6 +-
.../dsl/TypesafeAiComponentBuilderFactory.java | 2 +-
.../dsl/VertxHttpComponentBuilderFactory.java | 2 +-
.../builder/endpoint/EndpointHeaderBuilders.java | 4 +-
.../builder/endpoint/StaticEndpointBuilders.java | 16 +-
.../endpoint/dsl/AMQPEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/AWS2S3EndpointBuilderFactory.java | 62 +-
.../dsl/ActiveMQ6EndpointBuilderFactory.java | 20 +-
.../dsl/ActiveMQEndpointBuilderFactory.java | 20 +-
.../AlibabaEventBridgeEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/AvroEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/BlobEndpointBuilderFactory.java | 4 +-
.../dsl/CamelEventEndpointBuilderFactory.java | 12 +-
.../dsl/CassandraEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/CoAPEndpointBuilderFactory.java | 12 +-
.../dsl/CouchbaseEndpointBuilderFactory.java | 37 +-
.../endpoint/dsl/CxfEndpointBuilderFactory.java | 28 +-
.../endpoint/dsl/CxfRsEndpointBuilderFactory.java | 2 +-
.../dsl/CyberArkVaultEndpointBuilderFactory.java | 97 +-
.../endpoint/dsl/DaprEndpointBuilderFactory.java | 98 +-
.../endpoint/dsl/Ddb2EndpointBuilderFactory.java | 6 +-
.../dsl/DebeziumDb2EndpointBuilderFactory.java | 657 +++++++-
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 436 ++++-
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 404 ++++-
.../dsl/DebeziumOracleEndpointBuilderFactory.java | 417 ++++-
.../DebeziumPostgresEndpointBuilderFactory.java | 369 ++++-
.../DebeziumSqlserverEndpointBuilderFactory.java | 371 ++++-
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 83 +-
.../dsl/DoclingEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/ExecEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/FileEndpointBuilderFactory.java | 28 +-
.../dsl/FileWatchEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/FilesEndpointBuilderFactory.java | 194 +--
.../endpoint/dsl/FtpEndpointBuilderFactory.java | 194 +--
.../endpoint/dsl/FtpsEndpointBuilderFactory.java | 194 +--
.../GoogleMailStreamEndpointBuilderFactory.java | 2 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 6 +-
.../GoogleSheetsStreamEndpointBuilderFactory.java | 2 +-
.../dsl/GoogleVertexAIEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/GrpcEndpointBuilderFactory.java | 14 +-
.../dsl/HashicorpVaultEndpointBuilderFactory.java | 114 +-
.../HazelcastInstanceEndpointBuilderFactory.java | 2 +-
.../dsl/HazelcastListEndpointBuilderFactory.java | 2 +-
.../dsl/HazelcastMapEndpointBuilderFactory.java | 2 +-
.../HazelcastMultimapEndpointBuilderFactory.java | 2 +-
.../dsl/HazelcastQueueEndpointBuilderFactory.java | 2 +-
...zelcastReplicatedmapEndpointBuilderFactory.java | 2 +-
.../dsl/HazelcastSedaEndpointBuilderFactory.java | 30 +-
.../dsl/HazelcastSetEndpointBuilderFactory.java | 2 +-
.../dsl/HazelcastTopicEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/HttpEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/IBMCOSEndpointBuilderFactory.java | 6 +-
.../dsl/JGroupsEndpointBuilderFactory.java | 14 +-
.../dsl/JGroupsRaftEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/JdbcEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/JmsEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/JoltEndpointBuilderFactory.java | 8 +-
.../dsl/JsonataEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/Jt400EndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 104 +-
.../dsl/KeycloakEndpointBuilderFactory.java | 45 +-
.../dsl/Kinesis2EndpointBuilderFactory.java | 14 +-
.../KinesisFirehose2EndpointBuilderFactory.java | 2 +-
.../KubernetesEventsEndpointBuilderFactory.java | 2 +-
.../LangChain4jAgentEndpointBuilderFactory.java | 2 +-
.../dsl/LangChain4jChatEndpointBuilderFactory.java | 4 +-
...angChain4jEmbeddingsEndpointBuilderFactory.java | 2 +-
.../dsl/MicrometerEndpointBuilderFactory.java | 4 +-
.../dsl/MiloBrowseEndpointBuilderFactory.java | 8 +-
.../dsl/MiloClientEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/MinaEndpointBuilderFactory.java | 42 +-
.../dsl/MinaSftpEndpointBuilderFactory.java | 368 +----
.../endpoint/dsl/MinioEndpointBuilderFactory.java | 62 +-
.../endpoint/dsl/MllpEndpointBuilderFactory.java | 48 +-
.../dsl/MongoDbEndpointBuilderFactory.java | 28 +-
.../endpoint/dsl/NatsEndpointBuilderFactory.java | 18 +-
.../dsl/NetWeaverEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 8 +-
.../dsl/NettyHttpEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/OAIPMHEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/OpaEndpointBuilderFactory.java | 51 +-
.../endpoint/dsl/OpenAIEndpointBuilderFactory.java | 32 +-
.../dsl/OpenFgaEndpointBuilderFactory.java | 53 +-
.../dsl/OpenTelemetryEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/PQCEndpointBuilderFactory.java | 40 +
.../endpoint/dsl/PahoEndpointBuilderFactory.java | 24 +-
.../dsl/PahoMqtt5EndpointBuilderFactory.java | 24 +-
.../endpoint/dsl/PdfEndpointBuilderFactory.java | 10 +-
.../dsl/PgVectorEndpointBuilderFactory.java | 6 +-
.../PineconeVectorDbEndpointBuilderFactory.java | 15 +
.../dsl/PlatformHttpEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 12 +-
.../dsl/QuickfixjEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/RedisEndpointBuilderFactory.java | 18 +-
.../dsl/RestOpenApiEndpointBuilderFactory.java | 2 +-
.../dsl/RestPostmanEndpointBuilderFactory.java | 4 +-
.../dsl/RocketMQEndpointBuilderFactory.java | 15 +-
.../endpoint/dsl/STS2EndpointBuilderFactory.java | 10 +-
.../dsl/SalesforceEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/ScpEndpointBuilderFactory.java | 6 +-
.../dsl/SecretsManagerEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SedaEndpointBuilderFactory.java | 4 +-
.../dsl/ServiceBusEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SftpEndpointBuilderFactory.java | 374 +----
.../endpoint/dsl/Sjms2EndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/SjmsEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/SmbEndpointBuilderFactory.java | 222 +--
.../endpoint/dsl/SmppEndpointBuilderFactory.java | 185 +--
.../endpoint/dsl/Sns2EndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/SpiffeEndpointBuilderFactory.java | 6 +-
.../dsl/SplunkHECEndpointBuilderFactory.java | 2 +-
.../dsl/SpringAiChatEndpointBuilderFactory.java | 4 +-
.../dsl/SpringJdbcEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java | 46 +-
.../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 46 +-
.../endpoint/dsl/SshEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/StubEndpointBuilderFactory.java | 4 +-
.../dsl/TypeSafeAiEndpointBuilderFactory.java | 4 +-
.../dsl/UndertowEndpointBuilderFactory.java | 24 +-
.../dsl/VertxHttpEndpointBuilderFactory.java | 4 +-
.../dsl/WhatsAppEndpointBuilderFactory.java | 132 +-
.../META-INF/camel-jbang-commands-metadata.json | 4 +-
.../camel-jbang-configuration-metadata.json | 2 +-
.../apache/camel/dsl/jbang/core/commands/Run.java | 13 +-
.../core/commands/action/CamelChaosAction.java | 12 +
.../core/commands/action/CamelChaosAddAction.java | 32 +-
.../commands/action/CamelChaosChangeAction.java | 3 +-
.../commands/action/CamelChaosClearAction.java | 17 +-
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 73 +-
.../dsl/jbang/core/commands/ai/CatalogDocs.java | 5 +-
.../dsl/jbang/core/commands/ai/EndpointChecks.java | 51 +-
.../core/commands/ai/ExpressionEvaluator.java | 10 +-
.../dsl/jbang/core/commands/ai/HeaderChecks.java | 34 +
.../core/commands/ai/HeaderPropertyMixups.java | 393 +++++
.../dsl/jbang/core/commands/ai/LenientRepairs.java | 5 +
.../dsl/jbang/core/commands/ai/SimpleChecks.java | 224 ++-
.../jbang/core/commands/ai/SourceValidator.java | 9 +-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 42 +-
.../dsl/jbang/core/commands/process/ListChaos.java | 179 ++-
.../camel/dsl/jbang/core/commands/RunTest.java | 7 +-
.../core/commands/RunTransformMessageTest.java | 40 +
.../commands/ai/AuthoringToolsLenientTest.java | 67 +
.../ai/ExpressionEvaluatorLanguageTest.java | 4 +
.../core/commands/ai/HeaderPropertyMixupsTest.java | 152 +-
.../commands/ai/SourceValidatorEndpointTest.java | 101 ++
.../commands/ai/SourceValidatorSimpleTest.java | 217 ++-
.../jbang/core/commands/process/ListChaosTest.java | 190 ++-
.../src/test/resources/golden/cli-help.txt | 45 +-
.../golden/expected/maven-main-mixed.maven.txt | 2 +-
.../dsl/jbang/core/commands/mcp/RuntimeTools.java | 35 +-
.../core/commands/mcp/RuntimeToolsChaosTest.java | 15 +-
.../camel/dsl/jbang/core/commands/tui/AiPanel.java | 8 +-
.../commands/tui/AiPanelHistoryCompactionTest.java | 8 +
.../jbang/core/commands/tui/SourceSizeTest.java | 2 +-
.../apache/camel/dsl/jbang/run/RunPipeline.java | 8 +-
.../dsl/yaml/deserializers/ModelDeserializers.java | 12 +-
.../camel/dsl/yaml/validator/SchemaHints.java | 49 +
.../validator/YamlValidatorPropertyHintTest.java | 72 +
.../resources/schema/camelYamlDsl-canonical.json | 12 +-
.../resources/schema/camelYamlDsl-model.json | 12 +-
.../generated/resources/schema/camelYamlDsl.json | 12 +-
parent/pom.xml | 15 +-
test-infra/camel-test-infra-all/pom.xml | 44 +
.../src/generated/resources/META-INF/metadata.json | 621 ++++----
.../services/AbstractArtemisEmbeddedService.java | 14 +-
.../test/infra/azure/common/AzureProperties.java | 12 +
.../common/services/AzureStorageInfraService.java | 3 +-
.../azure/common/services/FlociAzContainer.java | 84 +
...eInfraService.java => FlociAzInfraService.java} | 64 +-
.../azure/common/services/container.properties | 10 +-
.../camel-test-infra-azure-eventgrid/pom.xml | 58 +
.../clients/AzureEventGridManagementClient.java | 157 ++
.../common/AzureEventGridProperties.java} | 15 +-
.../services/AzureEventGridInfraService.java | 59 +
.../AzureEventGridLocalContainerInfraService.java | 155 ++
.../services/AzureEventGridRemoteInfraService.java | 72 +
.../eventgrid/services/AzureEventGridService.java} | 13 +-
.../services/AzureEventGridServiceFactory.java | 101 ++
.../src/main/resources/META-INF/MANIFEST.MF | 0
.../camel-test-infra-azure-functions/pom.xml | 58 +
.../clients/AzureFunctionsClientUtils.java | 102 ++
.../services/AzureFunctionsInfraService.java | 48 +
.../AzureFunctionsLocalContainerInfraService.java | 74 +
.../services/AzureFunctionsRemoteInfraService.java | 64 +
.../functions/services/AzureFunctionsService.java} | 14 +-
.../services/AzureFunctionsServiceFactory.java | 87 +
.../src/main/resources/META-INF/MANIFEST.MF | 0
.../camel-test-infra-azure-key-vault}/pom.xml | 58 +-
.../azure/key/vault/AzureKeyVaultConfigs.java | 18 +-
.../vault/clients/AzureKeyVaultClientUtils.java | 97 ++
.../vault/services/AzureKeyVaultInfraService.java | 22 +-
.../AzureKeyVaultLocalContainerInfraService.java | 46 +
.../services/AzureKeyVaultRemoteInfraService.java | 60 +-
.../key/vault/services/AzureKeyVaultService.java} | 13 +-
.../services/AzureKeyVaultServiceFactory.java | 83 +
.../src/main/resources/META-INF/MANIFEST.MF | 0
.../camel-test-infra-azure-servicebus/pom.xml | 40 +
.../common/AzureServiceBusProperties.java} | 16 +-
.../services/AzureServiceBusInfraService.java} | 13 +-
.../AzureServiceBusLocalContainerInfraService.java | 213 +++
.../AzureServiceBusRemoteInfraService.java | 56 +-
.../services/AzureServiceBusService.java} | 9 +-
.../services/AzureServiceBusServiceFactory.java | 78 +
.../src/main/resources/META-INF/MANIFEST.MF | 0
.../infra/azure/servicebus/services/Config.json | 52 +
.../servicebus}/services/container.properties | 8 +-
...AzureStorageBlobLocalContainerInfraService.java | 6 +
.../clients/AzureStorageDataLakeClientUtils.java | 56 +-
...eStorageDataLakeLocalContainerInfraService.java | 33 +
.../AzureStorageDataLakeServiceFactory.java | 9 +-
...zureStorageQueueLocalContainerInfraService.java | 6 +
.../ListingCountingSftpEmbeddedService.java | 86 +
.../HashicorpVaultLocalContainerInfraService.java | 2 +
test-infra/pom.xml | 4 +
.../apache/camel/tooling/util/JavadocHelper.java | 5 +-
.../camel/tooling/util/JavadocHelperTest.java | 34 +
.../apache/camel/component/foo/FooEndpoint.java | 2 +-
.../src/it/HeaderSupport/verify.groovy | 5 +-
.../camel/maven/packaging/ComponentDslMojo.java | 2 +-
.../camel/maven/packaging/EndpointDslMojo.java | 2 +-
.../maven/packaging/GenerateChaosModelMojo.java | 76 +
.../camel/maven/packaging/PrepareCatalogMojo.java | 17 +
.../maven/packaging/UpdateSensitizeHelper.java | 2 +
.../camel/maven/packaging/dsl/DslHelper.java | 4 +
.../camel/maven/packaging/DslJavadocTest.java | 43 +
1125 files changed, 50623 insertions(+), 11573 deletions(-)
create mode 100644
.github/actions/check-container-upgrade/test_check_container_versions.py
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/chaos-model.json
create mode 100644
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/McpServerOrigins.java
create mode 100644
components/camel-ai/camel-mcp-server-api/src/test/java/org/apache/camel/component/mcp/server/McpServerOriginsTest.java
create mode 100644
components/camel-ai/camel-mcp-server/src/test/java/org/apache/camel/component/mcp/server/vertx/VertxMcpErrorResponseTest.java
create mode 100644
components/camel-ai/camel-mcp-server/src/test/java/org/apache/camel/component/mcp/server/vertx/VertxMcpOriginTest.java
create mode 100644
components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerGetRecordsLimitTest.java
create mode 100644
components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerGetEachObjectTest.java
create mode 100644
components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/AWS2S3ProducerGetObjectIgnoreBodyTest.java
create mode 100644
components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsConsumerMaxMessagesPerPollTest.java
create mode 100644
components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformerRouteTest.java
create mode 100644
components/camel-azure/camel-azure-eventgrid/src/test/java/org/apache/camel/component/azure/eventgrid/integration/EventGridProducerIT.java
create mode 100644
components/camel-azure/camel-azure-eventgrid/src/test/java/org/apache/camel/component/azure/eventgrid/integration/EventGridSubscriber.java
copy components/{camel-jetty =>
camel-azure/camel-azure-eventgrid}/src/test/resources/log4j2.properties (95%)
create mode 100644
components/camel-azure/camel-azure-files/src/test/java/org/apache/camel/component/file/azure/FilesEndpointReadLockTest.java
create mode 100644
components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/integration/operations/KeyVaultOperationsIT.java
delete mode 100644
components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/integration/operations/KeyVaultOperationsTest.java
rename
components/camel-azure/camel-azure-servicebus/src/test/java/org/apache/camel/component/azure/servicebus/integration/operations/{ServiceBusSenderOperationsTest.java
=> ServiceBusSenderOperationsIT.java} (95%)
create mode 100644
components/camel-chaos/src/generated/resources/META-INF/org/apache/camel/chaos/chaos-model.json
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosExchangeState.java
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosModel.java
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosRecentFaults.java
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosTargets.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosErrorHandlerExpectationTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosLiveStateTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosModelTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosReplyFaultsTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosRuleFeedbackTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosStartupClockTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosTimingFaultsTest.java
create mode 100644
components/camel-cyberark-vault/src/test/java/org/apache/camel/component/cyberark/vault/CyberArkVaultEndpointCredentialsTest.java
create mode 100644
components/camel-cyberark-vault/src/test/java/org/apache/camel/component/cyberark/vault/CyberArkVaultProducerTest.java
create mode 100644
components/camel-cyberark-vault/src/test/java/org/apache/camel/component/cyberark/vault/CyberArkVaultSslTest.java
create mode 100644
components/camel-cyberark-vault/src/test/java/org/apache/camel/component/cyberark/vault/client/impl/ConjurClientReauthenticationTest.java
create mode 100644
components/camel-cyberark-vault/src/test/java/org/apache/camel/component/cyberark/vault/client/impl/ConjurClientSecretVersionTest.java
create mode 100644
components/camel-cyberark-vault/src/test/resources/org/apache/camel/component/cyberark/vault/ssl/conjur-server.p12
create mode 100644
components/camel-cyberark-vault/src/test/resources/org/apache/camel/component/cyberark/vault/ssl/conjur-server.pem
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorMultipleConsumersLateConsumerTest.java
create mode 100644
components/camel-docker/src/test/java/org/apache/camel/component/docker/DockerClientFactoryTest.java
copy
components/camel-docker/src/test/java/org/apache/camel/component/docker/headers/{PullImageCmdHeaderTest.java
=> PullImageCmdRegistryAuthTest.java} (53%)
create mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileListingOperations.java
create mode 100644
components/camel-file/src/test/java/org/apache/camel/component/file/FileComponentPathSeparatorTest.java
create mode 100644
components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/RemoteFileEndpointReadLockTest.java
create mode 100644
components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/integration/SftpConsumerMaxMessagesPerPollListingIT.java
create mode 100644
components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/integration/SftpPostQuantumKeyExchangeIT.java
copy
components/{camel-disruptor/src/main/java/org/apache/camel/component/disruptor/SynchronizedExchange.java
=>
camel-git/src/test/java/org/apache/camel/component/git/consumer/GitConsumerFailedItemPooledExchangeTest.java}
(53%)
create mode 100644
components/camel-git/src/test/java/org/apache/camel/component/git/consumer/GitConsumerFailedItemTest.java
create mode 100644
components/camel-git/src/test/java/org/apache/camel/component/git/consumer/GitConsumerFirstPollTest.java
create mode 100644
components/camel-git/src/test/java/org/apache/camel/component/git/consumer/GitConsumerOptionsTest.java
create mode 100644
components/camel-git/src/test/java/org/apache/camel/component/git/consumer/RecordingExceptionHandler.java
create mode 100644
components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcPropagationRouteControlledTest.java
create mode 100644
components/camel-hashicorp-vault/src/main/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultAuthentication.java
create mode 100644
components/camel-hashicorp-vault/src/main/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultClient.java
create mode 100644
components/camel-hashicorp-vault/src/main/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultClientSettings.java
create mode 100644
components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/FakeVault.java
create mode 100644
components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultClientSettingsTest.java
create mode 100644
components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultClientTest.java
create mode 100644
components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/HashicorpVaultLoginTest.java
create mode 100644
components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/integration/HashicorpVaultLoginIT.java
create mode 100644
components/camel-jsch/src/test/java/org/apache/camel/component/scp/ScpFileNameControlCharTest.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerBreakOnFirstErrorPausedTest.java
create mode 100644
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletRouteRemovalBusyPoolTest.java
create mode 100644
components/camel-keycloak/src/test/java/org/apache/camel/component/keycloak/KeycloakProducerOperationHeaderTest.java
create mode 100644
components/camel-mina-sftp/src/test/java/org/apache/camel/component/file/remote/mina/MinaSftpEndpointReadLockTest.java
create mode 100644
components/camel-mina-sftp/src/test/java/org/apache/camel/component/file/remote/mina/integration/MinaSftpConsumerMaxMessagesPerPollListingIT.java
create mode 100644
components/camel-mina-sftp/src/test/java/org/apache/camel/component/file/remote/mina/integration/MinaSftpTcpNoDelayIT.java
create mode 100644
components/camel-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpServerPortInUseTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/PQCStatefulKeyAdoptionTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/PQCStatefulKeyClaimTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/crypto/hybrid/HybridKEMKeyLabelTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/lifecycle/FileBasedKeyLifecycleManagerStatefulClaimTest.java
create mode 100644
components/camel-smb/src/test/java/org/apache/camel/component/smb/SmbConsumerMaxMessagesPerPollListingIT.java
create mode 100644
components/camel-smb/src/test/java/org/apache/camel/component/smb/SmbEndpointReadLockTest.java
copy
test-infra/camel-test-infra-azure-common/src/main/resources/org/apache/camel/test/infra/azure/common/services/container.properties
=> components/camel-undertow/src/test/resources/spring.properties (73%)
create mode 100644
components/camel-whatsapp/src/test/java/org/apache/camel/component/whatsapp/WhatsAppWebhookStartupTest.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppProducerReconnectTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/cluster/RebalancingClusterServiceReleaseViewTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMaxMessagesPerPollListingTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerDoneFileNameAsyncLastFileTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/engine/RouteStartApplicationClassLoaderTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/MulticastOnCompletionThrowsTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/RecipientListProducerThrowsInDoTryTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/ShareUnitOfWorkSedaHandoverTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/SplitParallelShareUnitOfWorkHandoverTest.java
create mode 100644 design/exchange-sanitizer.adoc
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/commands/RunTransformMessageTest.java
create mode 100644
test-infra/camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/services/FlociAzContainer.java
copy
test-infra/camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/services/{AzureStorageInfraService.java
=> FlociAzInfraService.java} (50%)
create mode 100644 test-infra/camel-test-infra-azure-eventgrid/pom.xml
create mode 100644
test-infra/camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/clients/AzureEventGridManagementClient.java
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/common/AzureEventGridProperties.java}
(60%)
create mode 100644
test-infra/camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/services/AzureEventGridInfraService.java
create mode 100644
test-infra/camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/services/AzureEventGridLocalContainerInfraService.java
create mode 100644
test-infra/camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/services/AzureEventGridRemoteInfraService.java
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/services/AzureEventGridService.java}
(69%)
create mode 100644
test-infra/camel-test-infra-azure-eventgrid/src/main/java/org/apache/camel/test/infra/azure/eventgrid/services/AzureEventGridServiceFactory.java
copy test-infra/{camel-test-infra-arangodb =>
camel-test-infra-azure-eventgrid}/src/main/resources/META-INF/MANIFEST.MF (100%)
create mode 100644 test-infra/camel-test-infra-azure-functions/pom.xml
create mode 100644
test-infra/camel-test-infra-azure-functions/src/main/java/org/apache/camel/test/infra/azure/functions/clients/AzureFunctionsClientUtils.java
create mode 100644
test-infra/camel-test-infra-azure-functions/src/main/java/org/apache/camel/test/infra/azure/functions/services/AzureFunctionsInfraService.java
create mode 100644
test-infra/camel-test-infra-azure-functions/src/main/java/org/apache/camel/test/infra/azure/functions/services/AzureFunctionsLocalContainerInfraService.java
create mode 100644
test-infra/camel-test-infra-azure-functions/src/main/java/org/apache/camel/test/infra/azure/functions/services/AzureFunctionsRemoteInfraService.java
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-functions/src/main/java/org/apache/camel/test/infra/azure/functions/services/AzureFunctionsService.java}
(69%)
create mode 100644
test-infra/camel-test-infra-azure-functions/src/main/java/org/apache/camel/test/infra/azure/functions/services/AzureFunctionsServiceFactory.java
copy test-infra/{camel-test-infra-arangodb =>
camel-test-infra-azure-functions}/src/main/resources/META-INF/MANIFEST.MF (100%)
copy {components/camel-azure/camel-azure-eventgrid =>
test-infra/camel-test-infra-azure-key-vault}/pom.xml (55%)
copy
components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/SynchronizedExchange.java
=>
test-infra/camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/AzureKeyVaultConfigs.java
(60%)
create mode 100644
test-infra/camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/clients/AzureKeyVaultClientUtils.java
copy
components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/SynchronizedExchange.java
=>
test-infra/camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/services/AzureKeyVaultInfraService.java
(56%)
create mode 100644
test-infra/camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/services/AzureKeyVaultLocalContainerInfraService.java
copy
components/camel-pqc/src/main/java/org/apache/camel/component/pqc/PQCSymmetricAlgorithms.java
=>
test-infra/camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/services/AzureKeyVaultRemoteInfraService.java
(53%)
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/services/AzureKeyVaultService.java}
(69%)
create mode 100644
test-infra/camel-test-infra-azure-key-vault/src/main/java/org/apache/camel/test/infra/azure/key/vault/services/AzureKeyVaultServiceFactory.java
copy test-infra/{camel-test-infra-arangodb =>
camel-test-infra-azure-key-vault}/src/main/resources/META-INF/MANIFEST.MF (100%)
create mode 100644 test-infra/camel-test-infra-azure-servicebus/pom.xml
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/common/AzureServiceBusProperties.java}
(57%)
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/services/AzureServiceBusInfraService.java}
(64%)
create mode 100644
test-infra/camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/services/AzureServiceBusLocalContainerInfraService.java
copy
components/camel-pqc/src/main/java/org/apache/camel/component/pqc/PQCSymmetricAlgorithms.java
=>
test-infra/camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/services/AzureServiceBusRemoteInfraService.java
(53%)
copy
test-infra/{camel-test-infra-azure-common/src/main/java/org/apache/camel/test/infra/azure/common/AzureProperties.java
=>
camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/services/AzureServiceBusService.java}
(78%)
create mode 100644
test-infra/camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/services/AzureServiceBusServiceFactory.java
copy test-infra/{camel-test-infra-arangodb =>
camel-test-infra-azure-servicebus}/src/main/resources/META-INF/MANIFEST.MF
(100%)
create mode 100644
test-infra/camel-test-infra-azure-servicebus/src/main/resources/org/apache/camel/test/infra/azure/servicebus/services/Config.json
copy
test-infra/{camel-test-infra-azure-common/src/main/resources/org/apache/camel/test/infra/azure/common
=>
camel-test-infra-azure-servicebus/src/main/resources/org/apache/camel/test/infra/azure/servicebus}/services/container.properties
(62%)
create mode 100644
test-infra/camel-test-infra-azure-storage-datalake/src/main/java/org/apache/camel/test/infra/azure/storage/datalake/services/AzureStorageDataLakeLocalContainerInfraService.java
create mode 100644
test-infra/camel-test-infra-ftp/src/main/java/org/apache/camel/test/infra/ftp/services/embedded/ListingCountingSftpEmbeddedService.java
create mode 100644
tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/GenerateChaosModelMojo.java
create mode 100644
tooling/maven/camel-package-maven-plugin/src/test/java/org/apache/camel/maven/packaging/DslJavadocTest.java
