This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26627-debezium-3.7
in repository https://gitbox.apache.org/repos/asf/camel.git
omit 7cc03700d572 CAMEL-26627: camel-debezium-maven-plugin - fail with a
clear message when a config field is not static
omit 36d9d5e728ff CAMEL-26627: camel-debezium-mysql - link the upstream
issue for ddl.parser.type
omit cfae05c83fa4 CAMEL-26627: camel-debezium - Upgrade to Debezium
3.7.0.Final
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 fdd45f22593c CAMEL-26627: camel-debezium - Upgrade to Debezium
3.7.0.Final
add d5ac071c1584 CAMEL-26627: camel-debezium-mysql - link the upstream
issue for ddl.parser.type
add 6a0c48b10fca CAMEL-26627: camel-debezium-maven-plugin - fail with a
clear message when a config field is not static
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7cc03700d572)
\
N -- N -- N refs/heads/CAMEL-26627-debezium-3.7 (6a0c48b10fca)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../apache/camel/catalog/components/aws2-sqs.json | 3 +-
.../camel/catalog/components/azure-files.json | 2 +-
.../camel/catalog/components/cyberark-vault.json | 50 +--
.../apache/camel/catalog/components/docker.json | 42 ++-
.../org/apache/camel/catalog/components/file.json | 2 +-
.../org/apache/camel/catalog/components/ftp.json | 2 +-
.../org/apache/camel/catalog/components/ftps.json | 2 +-
.../camel/catalog/components/hashicorp-vault.json | 9 +-
.../apache/camel/catalog/components/keycloak.json | 10 +-
.../camel/catalog/components/micrometer.json | 2 +-
.../apache/camel/catalog/components/mina-sftp.json | 2 +-
.../catalog/components/opentelemetry-metrics.json | 2 +-
.../apache/camel/catalog/components/pinecone.json | 3 +-
.../org/apache/camel/catalog/components/pqc.json | 6 +-
.../org/apache/camel/catalog/components/sftp.json | 2 +-
.../org/apache/camel/catalog/components/smb.json | 2 +-
.../catalog/docs/cyberark-vault-component.adoc | 25 +-
.../camel/catalog/docs/docker-component.adoc | 16 +
.../catalog/docs/hashicorp-vault-component.adoc | 72 +++-
.../camel/catalog/docs/keycloak-producer.adoc | 11 +
.../org/apache/camel/catalog/docs/main.adoc | 11 +-
.../camel/catalog/docs/micrometer-component.adoc | 5 +
.../camel/catalog/docs/mina-sftp-component.adoc | 17 +
.../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/sftp-component.adoc | 26 ++
.../apache/camel/catalog/docs/smb-component.adoc | 10 +
.../org/apache/camel/catalog/docs/split-eip.adoc | 5 +
.../apache/camel/catalog/docs/ssh-component.adoc | 20 +
.../main/camel-main-configuration-metadata.json | 9 +-
.../apache/camel/catalog/main/sensitive-keys.json | 3 +
.../apache/camel/catalog/test-infra/metadata.json | 22 ++
.../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 +-
.../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 ++
.../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 +-
.../WeaviateEmbeddingsDataTypeTransformer.java | 5 +
.../WeaviateEmbeddingsDataTypeTransformerTest.java | 18 +-
.../transformer/aws2-ddb-application-x-struct.json | 6 +-
.../Ddb2JsonStructDataTypeTransformer.java | 44 ++-
.../Ddb2JsonStructDataTypeTransformerTest.java | 90 ++++-
.../apache/camel/component/aws2/sqs/aws2-sqs.json | 3 +-
.../camel/component/aws2/sqs/Sqs2Constants.java | 4 +
.../camel/component/aws2/sqs/Sqs2Consumer.java | 21 ++
.../AWS2SQSCloudEventDataTypeTransformer.java | 7 +-
...2SQSCloudEventDataTypeTransformerRouteTest.java | 118 ++++++
.../AWS2SQSCloudEventDataTypeTransformerTest.java | 16 +-
.../operations/CosmosDbDatabaseOperations.java | 4 +-
.../operations/CosmosDbDatabaseOperationsTest.java | 6 +
.../camel/component/file/azure/azure-files.json | 2 +-
.../camel-azure/camel-azure-key-vault/pom.xml | 9 +
.../operations/KeyVaultOperationsIT.java | 168 +++++++++
.../operations/KeyVaultOperationsTest.java | 110 ------
.../camel-azure-storage-datalake/pom.xml | 6 +
.../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 -
.../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 +
.../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 | 16 +
.../component/docker/DockerClientFactory.java | 40 +-
.../component/docker/DockerConfiguration.java | 18 +
.../camel/component/docker/DockerConstants.java | 41 ++-
.../component/docker/DockerClientFactoryTest.java | 225 ++++++++++++
.../docker/headers/AuthCmdHeaderTest.java | 6 +
.../docker/headers/BaseDockerHeaderTest.java | 22 +-
.../docker/headers/PushImageCmdHeaderTest.java | 6 +
.../ElasticsearchActionRequestConverter.java | 9 +-
.../ElasticsearchActionRequestConverterTest.java | 12 +
.../org/apache/camel/component/file/file.json | 2 +-
.../apache/camel/component/file/FileConsumer.java | 103 ++++--
.../camel/component/file/GenericFileConsumer.java | 13 +
.../camel/component/file/GenericFileEndpoint.java | 4 +-
.../file/GenericFileListingOperations.java | 47 +++
.../file/remote/AbstractSftpConsumer.java | 181 +++++++--
components/camel-ftp/pom.xml | 9 +
.../apache/camel/component/file/remote/ftp.json | 2 +-
.../apache/camel/component/file/remote/ftps.json | 2 +-
.../apache/camel/component/file/remote/sftp.json | 2 +-
.../camel-ftp/src/main/docs/sftp-component.adoc | 26 ++
.../component/file/remote/SftpOperations.java | 42 ++-
.../SftpConsumerMaxMessagesPerPollListingIT.java | 246 +++++++++++++
.../integration/SftpPostQuantumKeyExchangeIT.java | 61 ++++
...alendarStreamCloudEventDataTypeTransformer.java | 14 +-
...darStreamCloudEventDataTypeTransformerTest.java | 33 +-
.../groovy/DefaultGroovyScriptCompiler.java | 2 +-
.../camel/language/groovy/GroovyExpression.java | 11 +-
.../camel/language/groovy/GroovyLanguage.java | 65 +++-
.../groovy/GroovyCompilePreProcessorTest.java | 40 ++
.../groovy/GroovyMissingPropertyHintTest.java | 14 +
.../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 +++++++++
.../HazelcastReliableTopicConsumerLossTest.java | 11 +-
.../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 +
.../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 ++++++++
.../KubernetesCustomResourcesProducer.java | 8 +-
.../KubernetesCustomResourcesProducerTest.java | 21 ++
.../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 ++
components/camel-mina-sftp/pom.xml | 9 +
.../component/file/remote/mina/mina-sftp.json | 2 +-
.../src/main/docs/mina-sftp-component.adoc | 17 +
.../src/main/docs/mina-sftp-security.adoc | 48 ++-
.../file/remote/mina/MinaSftpOperations.java | 39 +-
...inaSftpConsumerMaxMessagesPerPollListingIT.java | 224 ++++++++++++
.../mina/integration/MinaSftpTcpNoDelayIT.java | 62 ++++
.../mina/sftp/SftpKeyExchangeProtocolsIT.java | 18 +
.../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 ++
.../http/vertx/VertxPlatformHttpServer.java | 26 +-
.../VertxPlatformHttpServerPortInUseTest.java | 67 ++++
.../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/smb/smb.json | 2 +-
.../camel-smb/src/main/docs/smb-component.adoc | 10 +
.../apache/camel/component/smb/SmbConsumer.java | 65 +++-
.../apache/camel/component/smb/SmbOperations.java | 51 +++
.../SmbConsumerMaxMessagesPerPollListingIT.java | 123 +++++++
.../camel-ssh/src/main/docs/ssh-component.adoc | 20 +
.../java/org/apache/camel/ExchangeExtension.java | 17 +
.../camel/vault/HashicorpVaultConfiguration.java | 136 ++++++-
.../camel/impl/engine/DefaultUnitOfWork.java | 87 ++++-
.../main/docs/modules/eips/pages/split-eip.adoc | 5 +
.../camel/language/simple/BaseSimpleParser.java | 4 +-
.../camel/language/simple/SimpleSyntaxHints.java | 76 ++++
.../apache/camel/processor/MulticastProcessor.java | 25 +-
.../RebalancingClusterServiceReleaseViewTest.java | 233 ++++++++++++
.../FileConsumeMaxMessagesPerPollListingTest.java | 156 ++++++++
.../language/simple/SimpleSyntaxHintsTest.java | 27 ++
.../processor/MulticastOnCompletionThrowsTest.java | 406 +++++++++++++++++++++
.../processor/ShareUnitOfWorkSedaHandoverTest.java | 319 ++++++++++++++++
.../SplitParallelShareUnitOfWorkHandoverTest.java | 212 +++++++++++
.../support/RouteWatcherReloadDataDirTest.java | 28 ++
.../HashicorpVaultConfigurationConfigurer.java | 33 ++
...corpVaultConfigurationPropertiesConfigurer.java | 40 ++
.../camel-main-configuration-metadata.json | 9 +-
core/camel-main/src/main/docs/main.adoc | 11 +-
.../HashicorpVaultConfigurationProperties.java | 56 +++
.../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 | 8 +
.../java/org/apache/camel/util/SensitiveUtils.java | 6 +
.../org/apache/camel/util/SensitiveUtilsTest.java | 5 +
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 32 ++
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 32 ++
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 290 +++++++++++++++
.../modules/ROOT/pages/camel-jbang-running.adoc | 4 +
docs/user-manual/modules/ROOT/pages/security.adoc | 16 +
.../dsl/CyberarkVaultComponentBuilderFactory.java | 74 ++--
.../dsl/DockerComponentBuilderFactory.java | 26 ++
.../dsl/KeycloakComponentBuilderFactory.java | 23 ++
.../component/dsl/PqcComponentBuilderFactory.java | 23 ++
.../dsl/CyberArkVaultEndpointBuilderFactory.java | 97 ++---
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 83 ++++-
.../endpoint/dsl/FileEndpointBuilderFactory.java | 22 +-
.../endpoint/dsl/FilesEndpointBuilderFactory.java | 22 +-
.../endpoint/dsl/FtpEndpointBuilderFactory.java | 22 +-
.../endpoint/dsl/FtpsEndpointBuilderFactory.java | 22 +-
.../dsl/HashicorpVaultEndpointBuilderFactory.java | 114 +++++-
.../dsl/KeycloakEndpointBuilderFactory.java | 45 ++-
.../dsl/MicrometerEndpointBuilderFactory.java | 4 +-
.../dsl/MinaSftpEndpointBuilderFactory.java | 22 +-
.../dsl/OpenTelemetryEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/PQCEndpointBuilderFactory.java | 40 ++
.../PineconeVectorDbEndpointBuilderFactory.java | 15 +
.../endpoint/dsl/SftpEndpointBuilderFactory.java | 22 +-
.../endpoint/dsl/SmbEndpointBuilderFactory.java | 22 +-
.../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 12 +
.../apache/camel/dsl/jbang/core/commands/Run.java | 13 +-
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 73 +++-
.../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 +-
.../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 ++++++++++-
.../golden/expected/maven-main-mixed.maven.txt | 2 +-
.../apache/camel/dsl/jbang/run/RunPipeline.java | 8 +-
.../camel/dsl/yaml/validator/SchemaHints.java | 49 +++
.../validator/YamlValidatorPropertyHintTest.java | 72 ++++
test-infra/camel-test-infra-all/pom.xml | 11 +
.../src/generated/resources/META-INF/metadata.json | 22 ++
.../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-key-vault}/pom.xml | 64 ++--
.../azure/key/vault/AzureKeyVaultConfigs.java} | 15 +-
.../vault/clients/AzureKeyVaultClientUtils.java | 97 +++++
.../vault/services/AzureKeyVaultInfraService.java} | 21 +-
.../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
...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 | 1 +
.../maven/packaging/UpdateSensitizeHelper.java | 2 +
342 files changed, 13481 insertions(+), 1130 deletions(-)
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-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
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-docker/src/test/java/org/apache/camel/component/docker/DockerClientFactoryTest.java
create mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileListingOperations.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
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-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/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
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/processor/MulticastOnCompletionThrowsTest.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
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%)
copy {components/camel-azure/camel-azure-key-vault =>
test-infra/camel-test-infra-azure-key-vault}/pom.xml (52%)
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/AzureKeyVaultConfigs.java}
(59%)
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
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/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-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
