This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26781-endpoint-reply-hits
in repository https://gitbox.apache.org/repos/asf/camel.git
from eb8c9b567f46 CAMEL-26781: camel-core - the runtime endpoint registry
counts the reply of an InOut consumer once per message
add 66000729edf0 CAMEL-26771: camel-chaos - what to try says how to feed
each route: by itself, curl, a file, or camel cmd send (#29462)
add 0902d342d4d2 CAMEL-25881: camel-mina-sftp, camel-ftp - fix flaky
SftpSimpleConsumeNoStartingDirIT
add b913894b86d9 CAMEL-26358: camel-mcp-server - run the official MCP
conformance suite against the Camel Main engine (#29186)
add 71f546438529 CAMEL-26618: camel-azure-eventhubs - run the integration
tests on Floci AZ (#29245)
add 0eebd4977602 CAMEL-26616: camel-azure-cosmosdb - run the integration
tests on Floci AZ (#29249)
add 3ebd42cac19d CAMEL-26748: camel-jbang - self-update and install.sh:
switch to a nightly SNAPSHOT build of the Camel CLI (#29428)
add a5667912eff8 CAMEL-26773: camel-chaos - the journal of an exploration:
a budget it enforces, the baseline, and the rules tried (#29466)
add 4209955441d8 CAMEL-26767: camel-jbang - camel cmd send: --repeat,
--interval and a folder of messages, to feed a route (#29459)
add 56aca3c1f6dc CAMEL-26640: Fix StreamCachingAdvice order to prevent
'Cannot reset stream from file' (#29257)
add a44c49fa3420 CAMEL-26740: camel-kafka - KafkaKeyValueRepository keys()
and size() fail once an entry has expired, and putIfAbsent can report an insert
that did not happen (#29434)
add 3a9e8701ffc0 Fix component docs that reference endpoint options which
do not exist (#29471)
add 7540c898e880 camel-printer: resolve mediaSize values whose case or
family prefix differ (#29472)
add 357ca829ba44 chore: camel-jbang - first row selected on Beans,
Configuration, Heap Histogram and Threads, the Timeline cursor hides the axis
label it is on, a JFR hint, and MCP waiting for a client is no error (#29477)
add b40d8b6c797b CAMEL-26775: ci - a PR whose diff the GitHub API refuses
is tested from the local diff (#29469)
add eb341770d40a CAMEL-26780: camel-core - the runtime endpoint registry
counts an input hit when an exchange enters the route (#29476)
add a74042df9dcf Merge main into CAMEL-26781 after CAMEL-26780 was
squash-merged
No new revisions were added by this update.
Summary of changes:
.github/CI-ARCHITECTURE.md | 4 +-
.../actions/incremental-build/incremental-build.sh | 43 +--
.github/actions/incremental-build/pr_diff.sh | 100 ++++++
.github/actions/incremental-build/pr_diff_test.sh | 121 +++++++
.github/workflows/pr-build-main.yml | 41 +--
.github/workflows/pr-ci-scripts-validation.yml | 8 +
.../catalog/docs/azure-cosmosdb-component.adoc | 19 +-
.../catalog/docs/azure-eventhubs-component.adoc | 12 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 61 +++-
.../camel/catalog/docs/cometd-component.adoc | 4 +-
.../camel/catalog/docs/mongodb-component.adoc | 2 +-
.../apache/camel/catalog/docs/netty-component.adoc | 6 +-
.../camel/catalog/docs/stitch-component.adoc | 4 +-
.../apache/camel/catalog/docs/timer-component.adoc | 2 +-
.../apache/camel/catalog/test-infra/metadata.json | 22 ++
components/camel-ai/camel-mcp-server/pom.xml | 39 +++
.../integration/OfficialMcpConformanceIT.java | 295 ++++++++++++++++
.../src/test/resources/expected-failures.yaml | 82 +++++
.../camel-ai/camel-mcp-server/test-execution.md | 41 +++
.../camel-azure/camel-azure-cosmosdb/pom.xml | 9 +
.../src/main/docs/azure-cosmosdb-component.adoc | 19 +-
.../azure/cosmosdb/CosmosDbTestUtils.java | 41 ++-
.../integration/BaseCamelCosmosDbTestSupport.java | 5 +
.../cosmosdb/integration/CosmosDbConsumerIT.java | 9 +-
.../cosmosdb/integration/CosmosDbProducerIT.java | 11 +-
.../operations/CosmosDbClientOperationsIT.java | 29 +-
.../operations/CosmosDbContainerOperationsIT.java | 54 +--
.../operations/CosmosDbDatabaseOperationsIT.java | 29 +-
.../camel-azure/camel-azure-eventhubs/pom.xml | 9 +
.../src/main/docs/azure-eventhubs-component.adoc | 12 +-
.../camel/component/azure/eventhubs/TestUtils.java | 39 ++-
.../eventhubs/integration/EventHubsConsumerIT.java | 43 ++-
.../EventHubsProducerCustomClientIT.java | 14 +-
.../eventhubs/integration/EventHubsProducerIT.java | 17 +-
.../eventhubs/integration/EventProcessorIT.java | 30 +-
.../operations/EventHubsProducerOperationsIT.java | 19 +-
components/camel-chaos/src/main/docs/chaos.adoc | 61 +++-
.../apache/camel/component/chaos/ChaosAdvisor.java | 97 +++++
.../camel/component/chaos/ChaosExploration.java | 187 ++++++++++
.../apache/camel/component/chaos/ChaosManager.java | 156 ++++++++-
.../apache/camel/component/chaos/ChaosReport.java | 15 +
.../component/chaos/ChaosExplorationTest.java | 204 +++++++++++
.../camel/component/chaos/ChaosFeedTest.java | 104 ++++++
.../src/main/docs/cometd-component.adoc | 4 +-
.../SftpSimpleConsumeNoStartingDirIT.java | 25 +-
.../keyvalue/kafka/KafkaKeyValueRepository.java | 35 +-
.../kafka/KafkaKeyValueRepositoryTest.java | 189 ++++++++++
.../sftp/SftpSimpleConsumeNoStartingDirIT.java | 25 +-
.../src/main/docs/mongodb-component.adoc | 2 +-
.../camel-netty/src/main/docs/netty-component.adoc | 6 +-
.../camel/component/printer/MediaSizeAssigner.java | 37 +-
.../component/printer/PrinterConfiguration.java | 16 +-
.../component/printer/MediaSizeAssignerTest.java | 73 ++++
.../src/main/docs/stitch-component.adoc | 4 +-
.../camel-timer/src/main/docs/timer-component.adoc | 2 +-
.../camel/impl/engine/CamelInternalProcessor.java | 24 +-
.../engine/DefaultRuntimeEndpointRegistry.java | 4 +-
.../apache/camel/impl/console/SendDevConsole.java | 12 +-
.../camel/impl/console/SendDevConsoleTest.java | 25 ++
.../RouteStreamCachingSpoolAdviceOrderTest.java | 181 ++++++++++
.../modules/ROOT/pages/camel-jbang-devtools.adoc | 32 ++
.../ROOT/pages/camel-jbang-launcher-install.adoc | 71 +++-
.../ROOT/pages/camel-jbang-tui-ai-agents.adoc | 2 +-
.../pages/jbang-commands/camel-jbang-cmd-send.adoc | 2 +
.../apache/camel/cli/connector/ChaosAction.java | 13 +-
.../camel/cli/connector/LocalCliConnector.java | 139 ++++++--
.../apache/camel/cli/connector/RepeatedSend.java | 240 +++++++++++++
.../LocalCliConnectorChaosActionTest.java | 26 ++
.../connector/LocalCliConnectorSendActionTest.java | 228 ++++++++++++
.../META-INF/camel-jbang-commands-metadata.json | 2 +-
.../commands/action/CamelChaosSuggestAction.java | 11 +-
.../core/commands/action/CamelSendAction.java | 123 ++++++-
.../dsl/jbang/core/commands/ai/ToolContext.java | 6 +-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 44 ++-
.../dsl/jbang/core/commands/process/ListChaos.java | 44 +++
.../jbang/core/commands/version/VersionGet.java | 11 +
.../dsl/jbang/core/common/InstallDetector.java | 64 ++++
.../camel/dsl/jbang/core/common/RuntimeHelper.java | 43 ++-
.../core/commands/action/CamelChaosActionTest.java | 33 ++
.../commands/action/CamelSendActionResultTest.java | 73 ++++
.../jbang/core/commands/ai/RuntimeToolsTest.java | 11 +
.../jbang/core/commands/process/ListChaosTest.java | 25 ++
.../core/commands/version/VersionGetTest.java | 30 ++
.../dsl/jbang/core/common/InstallDetectorTest.java | 26 ++
.../dsl/jbang/core/common/RuntimeHelperTest.java | 17 +
.../src/test/resources/golden/cli-help.txt | 29 +-
.../dsl/jbang/core/commands/mcp/RuntimeTools.java | 28 +-
.../jbang/core/commands/mcp/RuntimeToolsTest.java | 2 +-
.../core/commands/mcp/RuntimeToolsWiringTest.java | 3 +-
.../dsl/jbang/core/commands/tui/BeansTab.java | 6 +
.../dsl/jbang/core/commands/tui/CamelMonitor.java | 5 +-
.../jbang/core/commands/tui/CircuitBreakerTab.java | 3 +-
.../jbang/core/commands/tui/ConfigurationTab.java | 6 +
.../jbang/core/commands/tui/HeapHistogramTab.java | 6 +
.../camel/dsl/jbang/core/commands/tui/JfrTab.java | 13 +-
.../dsl/jbang/core/commands/tui/ThreadsTab.java | 6 +
.../dsl/jbang/core/commands/tui/TimelineTab.java | 23 +-
.../commands/tui/ConfigurationTabRenderTest.java | 16 +
.../jbang/core/commands/tui/JfrTabRenderTest.java | 28 ++
.../core/commands/tui/TimelineTabRenderTest.java | 18 +
.../camel-launcher/src/install/install.sh | 208 ++++++++++-
.../jbang/launcher/selfupdate/ManifestFetcher.java | 185 +++++++++-
.../dsl/jbang/launcher/selfupdate/Nightly.java | 131 +++++++
.../camel/dsl/jbang/launcher/selfupdate/Pin.java | 34 +-
.../launcher/selfupdate/SelfUpdateCommand.java | 233 ++++++++++--
.../jbang/launcher/selfupdate/UpdateChecker.java | 10 +-
.../jbang/launcher/SelfUpdateIntegrationTest.java | 390 ++++++++++++++++++++-
.../dsl/jbang/launcher/WebsiteInstallTest.java | 390 ++++++++++++++++++++-
.../jbang/launcher/WebsiteInstallerFixture.java | 5 +
.../launcher/selfupdate/ManifestFetcherTest.java | 185 ++++++++++
.../dsl/jbang/launcher/selfupdate/NightlyTest.java | 83 +++++
.../dsl/jbang/launcher/selfupdate/PinTest.java | 45 ++-
.../launcher/selfupdate/SelfUpdateCommandTest.java | 36 +-
.../launcher/selfupdate/UpdateCheckerTest.java | 12 +
test-infra/camel-test-infra-all/pom.xml | 22 ++
.../src/generated/resources/META-INF/metadata.json | 22 ++
.../test/infra/azure/common/AzureProperties.java | 6 +
.../azure/common/services/FlociAzContainer.java | 109 ++++++
.../azure/common/services/container.properties | 6 +
test-infra/camel-test-infra-azure-cosmosdb/pom.xml | 58 +++
.../cosmosdb/clients/AzureCosmosDbClientUtils.java | 87 +++++
.../cosmosdb/common/AzureCosmosDbProperties.java} | 20 +-
.../services/AzureCosmosDbInfraService.java} | 25 +-
.../AzureCosmosDbLocalContainerInfraService.java | 93 +++++
.../services/AzureCosmosDbRemoteInfraService.java | 52 +++
.../cosmosdb/services/AzureCosmosDbService.java} | 18 +-
.../services/AzureCosmosDbServiceFactory.java | 78 +++++
.../src/main/resources/META-INF/MANIFEST.MF | 0
.../camel-test-infra-azure-eventhubs/pom.xml | 58 +++
.../clients/AzureEventHubsClientUtils.java | 44 +++
.../eventhubs/common/AzureEventHubsProperties.java | 39 +++
.../services/AzureEventHubsInfraService.java} | 27 +-
.../AzureEventHubsLocalContainerInfraService.java | 201 +++++++++++
.../services/AzureEventHubsRemoteInfraService.java | 62 ++++
.../eventhubs/services/AzureEventHubsService.java} | 21 +-
.../services/AzureEventHubsServiceFactory.java | 92 +++++
.../common/AzureServiceBusProperties.java | 4 -
.../AzureServiceBusLocalContainerInfraService.java | 99 +-----
.../azure/servicebus/services/container.properties | 22 --
test-infra/pom.xml | 2 +
140 files changed, 6869 insertions(+), 636 deletions(-)
create mode 100644 .github/actions/incremental-build/pr_diff.sh
create mode 100755 .github/actions/incremental-build/pr_diff_test.sh
create mode 100644
components/camel-ai/camel-mcp-server/src/test/java/org/apache/camel/component/mcp/server/vertx/integration/OfficialMcpConformanceIT.java
create mode 100644
components/camel-ai/camel-mcp-server/src/test/resources/expected-failures.yaml
create mode 100644
components/camel-chaos/src/main/java/org/apache/camel/component/chaos/ChaosExploration.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosExplorationTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosFeedTest.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/processor/keyvalue/kafka/KafkaKeyValueRepositoryTest.java
create mode 100644
components/camel-printer/src/test/java/org/apache/camel/component/printer/MediaSizeAssignerTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/RouteStreamCachingSpoolAdviceOrderTest.java
create mode 100644
dsl/camel-cli-connector/src/main/java/org/apache/camel/cli/connector/RepeatedSend.java
create mode 100644
dsl/camel-cli-connector/src/test/java/org/apache/camel/cli/connector/LocalCliConnectorSendActionTest.java
create mode 100644
dsl/camel-jbang/camel-launcher/src/main/java/org/apache/camel/dsl/jbang/launcher/selfupdate/Nightly.java
create mode 100644
dsl/camel-jbang/camel-launcher/src/test/java/org/apache/camel/dsl/jbang/launcher/selfupdate/NightlyTest.java
create mode 100644 test-infra/camel-test-infra-azure-cosmosdb/pom.xml
create mode 100644
test-infra/camel-test-infra-azure-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/clients/AzureCosmosDbClientUtils.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-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/common/AzureCosmosDbProperties.java}
(53%)
copy
test-infra/{camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/common/AzureServiceBusProperties.java
=>
camel-test-infra-azure-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/services/AzureCosmosDbInfraService.java}
(55%)
create mode 100644
test-infra/camel-test-infra-azure-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/services/AzureCosmosDbLocalContainerInfraService.java
create mode 100644
test-infra/camel-test-infra-azure-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/services/AzureCosmosDbRemoteInfraService.java
copy
test-infra/{camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/common/AzureServiceBusProperties.java
=>
camel-test-infra-azure-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/services/AzureCosmosDbService.java}
(57%)
create mode 100644
test-infra/camel-test-infra-azure-cosmosdb/src/main/java/org/apache/camel/test/infra/azure/cosmosdb/services/AzureCosmosDbServiceFactory.java
copy test-infra/{camel-test-infra-arangodb =>
camel-test-infra-azure-cosmosdb}/src/main/resources/META-INF/MANIFEST.MF (100%)
create mode 100644 test-infra/camel-test-infra-azure-eventhubs/pom.xml
create mode 100644
test-infra/camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/clients/AzureEventHubsClientUtils.java
create mode 100644
test-infra/camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/common/AzureEventHubsProperties.java
copy
test-infra/{camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/common/AzureServiceBusProperties.java
=>
camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/services/AzureEventHubsInfraService.java}
(50%)
create mode 100644
test-infra/camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/services/AzureEventHubsLocalContainerInfraService.java
create mode 100644
test-infra/camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/services/AzureEventHubsRemoteInfraService.java
copy
test-infra/{camel-test-infra-azure-servicebus/src/main/java/org/apache/camel/test/infra/azure/servicebus/common/AzureServiceBusProperties.java
=>
camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/services/AzureEventHubsService.java}
(57%)
create mode 100644
test-infra/camel-test-infra-azure-eventhubs/src/main/java/org/apache/camel/test/infra/azure/eventhubs/services/AzureEventHubsServiceFactory.java
delete mode 100644
test-infra/camel-test-infra-azure-servicebus/src/main/resources/org/apache/camel/test/infra/azure/servicebus/services/container.properties
