This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26789-experiment-lost-at-dlq
in repository https://gitbox.apache.org/repos/asf/camel.git
from e9a2b1a315ae CAMEL-26789: camel-chaos - an experiment fails when its
rules lost messages at the dead letter channel, as the report does
add 9e4372970dbd Ignore .bob directory and exclude from license checks
(#29497)
add 063cced3f550 CAMEL-26593: camel-kafka - run the ITs in 4 parallel
forks and drop the serials groups (#29494)
add 3fd480282421 CAMEL-26355: Add MCP prompts from Camel routes (#29454)
add 3dcc374d3e34 CAMEL-26785: camel-management - the steps of a circuit
breaker's onFallback are processors of the route (#29490)
add 7cce4ff2f34a CAMEL-26781: camel-core - the runtime endpoint registry
counts the reply of an InOut consumer once per message (#29478)
add 72fbc1a97df8 CAMEL-26786: camel-jbang - camel cmd chaos-experiment:
one experiment in one call, with its traffic and the wait for its verdict
(#29498)
add 6264c4653806 chore: camel-jbang - Events shows one category at a time
with f, and Startup is a waterfall with the slowest first on s (#29507)
add 09e606b1fafb chore: camel-jbang - the topology and About's Out show
what a recipient list or a toD sent to, as the runtime saw it (#29508)
add e4c63e37377c chore: camel-jbang - the flow of Endpoints counts the
messages that come in and go out, not the hand-offs between the routes (#29510)
add b9969d98cdfe chore: camel-jbang - the strips of What happened are in
the order of the routes, a called route after its caller (#29511)
add fac088073e26 chore: camel-jbang - Memory Leak says where each sample
was allocated, so two leaks of byte[] are told apart (#29513)
add e15dfe4e943e Merge remote-tracking branch 'origin/main' into
CAMEL-26789-experiment-lost-at-dlq
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
bom/camel-bom/pom.xml | 5 +
catalog/camel-allcomponents/pom.xml | 5 +
.../org/apache/camel/catalog/components.properties | 1 +
.../apache/camel/catalog/components/ai-prompt.json | 49 ++++
.../org/apache/camel/catalog/docs.properties | 1 +
.../org/apache/camel/catalog/docs/ai-patterns.adoc | 5 +-
.../camel/catalog/docs/ai-prompt-component.adoc | 103 +++++++
.../org/apache/camel/catalog/docs/chaos.adoc | 4 +
.../org/apache/camel/catalog/docs/main.adoc | 9 +-
.../org/apache/camel/catalog/docs/mcp-server.adoc | 69 +++--
.../main/camel-main-configuration-metadata.json | 7 +-
.../apache/camel/catalog/others/mcp-server.json | 2 +-
components/camel-ai/camel-ai-prompt/pom.xml | 64 +++++
.../ai/prompt/AiPromptComponentConfigurer.java | 88 ++++++
.../ai/prompt/AiPromptConfigurationConfigurer.java | 66 +++++
.../ai/prompt/AiPromptEndpointConfigurer.java | 84 ++++++
.../ai/prompt/AiPromptEndpointUriFactory.java | 86 ++++++
.../camel/component/ai/prompt/ai-prompt.json | 49 ++++
.../services/org/apache/camel/component.properties | 7 +
.../services/org/apache/camel/component/ai-prompt | 2 +
.../apache/camel/configurer/ai-prompt-component | 2 +
.../org/apache/camel/configurer/ai-prompt-endpoint | 2 +
...camel.component.ai.prompt.AiPromptConfiguration | 2 +
.../org/apache/camel/urifactory/ai-prompt-endpoint | 2 +
.../src/main/docs/ai-prompt-component.adoc | 103 +++++++
.../apache/camel/component/ai/prompt/AiPrompt.java | 30 ++
.../component/ai/prompt/AiPromptArgument.java | 28 ++
.../component/ai/prompt/AiPromptComponent.java | 115 ++++++++
.../component/ai/prompt/AiPromptConfiguration.java | 101 +++++++
.../component/ai/prompt/AiPromptConsumer.java | 201 +++++++++++++
.../component/ai/prompt/AiPromptEndpoint.java | 115 ++++++++
.../component/ai/prompt/AiPromptExecutor.java | 109 +++++++
.../component/ai/prompt/AiPromptRegistry.java | 238 +++++++++++++++
.../ai/prompt/AiPromptRegistryListener.java | 29 ++
.../camel/component/ai/prompt/AiPromptResult.java | 34 +++
.../camel/component/ai/prompt/AiPromptSpec.java | 101 +++++++
.../component/ai/prompt/AiPromptComponentTest.java | 112 ++++++++
.../ai/prompt/AiPromptEndpointLifecycleTest.java | 103 +++++++
.../ai/prompt/AiPromptStartupOrderTest.java | 92 ++++++
components/camel-ai/camel-mcp-server-api/pom.xml | 6 +-
.../services/org/apache/camel/other.properties | 2 +-
.../src/generated/resources/mcp-server-api.json | 2 +-
...efusedException.java => McpPromptArgument.java} | 19 +-
...RefusedException.java => McpPromptHandler.java} | 20 +-
...RefusedException.java => McpPromptMessage.java} | 19 +-
...rRefusedException.java => McpPromptResult.java} | 32 ++-
.../component/mcp/server/McpServerBridge.java | 250 +++++++++++++++-
.../mcp/server/McpServerConfiguration.java | 13 +
.../component/mcp/server/McpServerConstants.java | 5 +
.../component/mcp/server/McpServerEngine.java | 34 ++-
...rRefusedException.java => McpServerPrompt.java} | 28 +-
.../mcp/server/McpServerRefusedException.java | 9 +-
.../server/McpServerBridgeEngineRefusalTest.java | 55 +++-
.../mcp/server/McpServerBridgePromptTest.java | 184 ++++++++++++
.../mcp/server/RecordingMcpServerEngine.java | 29 +-
.../McpServerPromptConformanceTestSupport.java | 186 ++++++++++++
components/camel-ai/camel-mcp-server/pom.xml | 2 +-
.../services/org/apache/camel/other.properties | 2 +-
.../src/generated/resources/mcp-server.json | 2 +-
.../camel-mcp-server/src/main/docs/mcp-server.adoc | 69 +++--
.../component/mcp/server/McpPromptSdkSupport.java | 114 ++++++++
.../mcp/server/main/DefaultMcpServerFactory.java | 1 +
.../mcp/server/stdio/StdioMcpServerEngine.java | 63 +++-
.../mcp/server/vertx/VertxMcpServerEngine.java | 27 +-
.../mcp/server/stdio/StdioMcpServerEngineTest.java | 75 ++++-
.../vertx/VertxMcpServerPromptConformanceTest.java | 41 +++
components/camel-ai/pom.xml | 1 +
components/camel-chaos/src/main/docs/chaos.adoc | 4 +
components/camel-kafka/pom.xml | 20 +-
...eakOnFirstErrorOffUsingKafkaManualCommitIT.java | 3 -
.../KafkaBreakOnFirstErrorReleaseResourcesIT.java | 1 -
.../KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 3 -
.../KafkaBreakOnFirstErrorSeekIssueIT.java | 3 -
...rstErrorWithBatchUsingAsyncCommitManagerIT.java | 3 -
...irstErrorWithBatchUsingKafkaManualCommitIT.java | 3 -
...rrorWithBatchUsingKafkaManualCommitRetryIT.java | 3 -
...irstErrorWithBatchUsingSyncCommitManagerIT.java | 3 -
.../integration/KafkaConsumerIdempotentIT.java | 3 -
.../kafka/integration/KafkaExactlyOnceIT.java | 3 -
.../integration/KafkaExactlyOnceRebalanceIT.java | 3 -
.../integration/KafkaExactlyOnceRegressionIT.java | 3 -
.../health/KafkaConsumerBadPortHealthCheckIT.java | 3 -
...fkaConsumerBadPortSupervisingHealthCheckIT.java | 3 -
.../KafkaConsumerGroupProtocolHealthCheckIT.java | 3 -
.../health/KafkaConsumerHealthCheckIT.java | 3 -
.../KafkaConsumerUnresolvableHealthCheckIT.java | 3 -
.../ResilienceFallbackManagementTest.java | 86 ++++++
.../resilience4j/ResilienceInputHitsTest.java | 13 +-
.../engine/DefaultRuntimeEndpointRegistry.java | 99 ++++---
.../main/docs/modules/eips/pages/ai-patterns.adoc | 5 +-
...ttpServerConfigurationPropertiesConfigurer.java | 7 +
.../camel-main-configuration-metadata.json | 7 +-
.../org/apache/camel/main/components.properties | 1 +
core/camel-main/src/main/docs/main.adoc | 9 +-
.../main/HttpServerConfigurationProperties.java | 51 +++-
.../management/JmxManagementLifecycleStrategy.java | 9 +
.../management/ManagedEndpointReplyHitsTest.java | 100 +++++++
.../java/org/apache/camel/util/ArtifactUtils.java | 1 +
.../modules/ROOT/examples/json/ai-prompt.json | 1 +
docs/components/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/ai-prompt-component.adoc | 1 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 6 +-
.../modules/ROOT/pages/camel-jbang-managing.adoc | 30 ++
.../camel-jbang-cmd-chaos-experiment.adoc | 36 +++
.../camel-jbang-cmd-chaos-explore-finish.adoc | 26 ++
.../camel-jbang-cmd-chaos-explore-start.adoc | 28 ++
.../ROOT/pages/jbang-commands/camel-jbang-cmd.adoc | 3 +
.../component/ComponentsBuilderFactory.java | 13 +
.../dsl/AiPromptComponentBuilderFactory.java | 218 ++++++++++++++
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/StaticEndpointBuilders.java | 40 +++
.../dsl/AiPromptEndpointBuilderFactory.java | 318 +++++++++++++++++++++
.../META-INF/camel-jbang-commands-metadata.json | 2 +-
.../dsl/jbang/core/commands/CamelJBangMain.java | 3 +
.../action/CamelChaosExperimentAction.java | 241 ++++++++++++++++
.../action/CamelChaosExploreFinishAction.java | 71 +++++
.../action/CamelChaosExploreStartAction.java | 75 +++++
.../dsl/jbang/core/commands/process/ListChaos.java | 29 +-
.../dsl/jbang/core/common/ChaosExperimentRun.java | 245 ++++++++++++++++
.../core/commands/action/CamelChaosActionTest.java | 102 ++++++-
.../jbang/core/common/ChaosExperimentRunTest.java | 204 +++++++++++++
.../src/test/resources/golden/cli-help.txt | 211 +++++++++++---
.../dsl/jbang/core/commands/tui/AboutView.java | 38 ++-
.../jbang/core/commands/tui/DiagramTopology.java | 48 ++++
.../dsl/jbang/core/commands/tui/EndpointFlow.java | 59 ++++
.../dsl/jbang/core/commands/tui/EndpointsTab.java | 11 +-
.../dsl/jbang/core/commands/tui/EventTab.java | 43 ++-
.../dsl/jbang/core/commands/tui/LeakSite.java | 60 ++++
.../dsl/jbang/core/commands/tui/MemoryLeakTab.java | 2 +-
.../jbang/core/commands/tui/MetricsCollector.java | 9 +-
.../dsl/jbang/core/commands/tui/ObservedOuts.java | 109 +++++++
.../dsl/jbang/core/commands/tui/StartupTab.java | 68 +++--
.../src/main/resources/tui/help/endpoints.md | 7 +
.../src/main/resources/tui/help/event.md | 3 +
.../src/main/resources/tui/help/memory-leak.md | 2 +-
.../src/main/resources/tui/help/overview.md | 5 +-
.../src/main/resources/tui/help/startup.md | 32 +--
.../dsl/jbang/core/commands/tui/AboutViewTest.java | 41 +++
.../core/commands/tui/DiagramTopologyTest.java | 39 +++
.../jbang/core/commands/tui/EndpointFlowTest.java | 54 ++++
.../jbang/core/commands/tui/EventTabOrderTest.java | 24 ++
.../dsl/jbang/core/commands/tui/LeakSiteTest.java | 54 ++++
.../jbang/core/commands/tui/ObservedOutsTest.java | 83 ++++++
.../core/commands/tui/StartupTabRenderTest.java | 24 ++
.../camel-component-known-dependencies.properties | 1 +
parent/pom.xml | 5 +
pom.xml | 2 +
.../apache/camel/maven/packaging/MojoHelper.java | 2 +-
150 files changed, 6311 insertions(+), 397 deletions(-)
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/ai-prompt.json
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/ai-prompt-component.adoc
create mode 100644 components/camel-ai/camel-ai-prompt/pom.xml
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/java/org/apache/camel/component/ai/prompt/AiPromptComponentConfigurer.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/java/org/apache/camel/component/ai/prompt/AiPromptConfigurationConfigurer.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/java/org/apache/camel/component/ai/prompt/AiPromptEndpointConfigurer.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/java/org/apache/camel/component/ai/prompt/AiPromptEndpointUriFactory.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/org/apache/camel/component/ai/prompt/ai-prompt.json
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/services/org/apache/camel/component.properties
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/services/org/apache/camel/component/ai-prompt
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/services/org/apache/camel/configurer/ai-prompt-component
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/services/org/apache/camel/configurer/ai-prompt-endpoint
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/services/org/apache/camel/configurer/org.apache.camel.component.ai.prompt.AiPromptConfiguration
create mode 100644
components/camel-ai/camel-ai-prompt/src/generated/resources/META-INF/services/org/apache/camel/urifactory/ai-prompt-endpoint
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/docs/ai-prompt-component.adoc
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPrompt.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptArgument.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptComponent.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptConfiguration.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptConsumer.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptEndpoint.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptExecutor.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptRegistry.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptRegistryListener.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptResult.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/main/java/org/apache/camel/component/ai/prompt/AiPromptSpec.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/test/java/org/apache/camel/component/ai/prompt/AiPromptComponentTest.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/test/java/org/apache/camel/component/ai/prompt/AiPromptEndpointLifecycleTest.java
create mode 100644
components/camel-ai/camel-ai-prompt/src/test/java/org/apache/camel/component/ai/prompt/AiPromptStartupOrderTest.java
copy
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/{McpServerRefusedException.java
=> McpPromptArgument.java} (51%)
copy
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/{McpServerRefusedException.java
=> McpPromptHandler.java} (51%)
copy
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/{McpServerRefusedException.java
=> McpPromptMessage.java} (51%)
copy
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/{McpServerRefusedException.java
=> McpPromptResult.java} (50%)
copy
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/{McpServerRefusedException.java
=> McpServerPrompt.java} (51%)
create mode 100644
components/camel-ai/camel-mcp-server-api/src/test/java/org/apache/camel/component/mcp/server/McpServerBridgePromptTest.java
create mode 100644
components/camel-ai/camel-mcp-server-api/src/test/java/org/apache/camel/component/mcp/server/conformance/McpServerPromptConformanceTestSupport.java
create mode 100644
components/camel-ai/camel-mcp-server/src/main/java/org/apache/camel/component/mcp/server/McpPromptSdkSupport.java
create mode 100644
components/camel-ai/camel-mcp-server/src/test/java/org/apache/camel/component/mcp/server/vertx/VertxMcpServerPromptConformanceTest.java
create mode 100644
components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceFallbackManagementTest.java
create mode 100644
core/camel-management/src/test/java/org/apache/camel/management/ManagedEndpointReplyHitsTest.java
create mode 120000 docs/components/modules/ROOT/examples/json/ai-prompt.json
create mode 120000 docs/components/modules/ROOT/pages/ai-prompt-component.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-experiment.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-explore-finish.adoc
create mode 100644
docs/user-manual/modules/ROOT/pages/jbang-commands/camel-jbang-cmd-chaos-explore-start.adoc
create mode 100644
dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AiPromptComponentBuilderFactory.java
create mode 100644
dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AiPromptEndpointBuilderFactory.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosExperimentAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosExploreFinishAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelChaosExploreStartAction.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/common/ChaosExperimentRun.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/common/ChaosExperimentRunTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/EndpointFlow.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/LeakSite.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/ObservedOuts.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/EndpointFlowTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/LeakSiteTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/ObservedOutsTest.java
