This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch feature/CAMEL-25429-error-layer
in repository https://gitbox.apache.org/repos/asf/camel.git
discard efac61d5f686 CAMEL-25429: review nits, the error labels are built once
per widget; drop an unused method
discard 29786e0538ae CAMEL-25429: camel-jbang - the error frame has no arrows;
a mark on routes with error handling
discard 570d726637a0 CAMEL-25429: camel-jbang - monitor docs and MCP tool text
describe the error handling
discard 2f8214a36d26 CAMEL-25429: camel-jbang - F1 help of the route diagram
describes x
discard e5f9fea95531 CAMEL-25429: camel-jbang - the route view shows its error
handling in a frame of its own
discard a38eefa750b4 CAMEL-25429: camel-jbang - the monitor draws the error
handling in a frame of its own
omit 07bab3754efc CAMEL-25429: review nit, group the conditions of
handling()
omit 78590ed7eb2f CAMEL-25429: route topology - an error path says what
happens to the failure
omit 84ca959045e1 CAMEL-25429: route topology - error paths are not calls
between routes
add d3cf0051628a CAMEL-25382: Introduce expert-owned semantic evaluation
contracts
add 2ebad42055d0 CAMEL-25382: Address semantic contract review feedback
add efe1577aaa61 CAMEL-25382: Preserve literal braces in semantic
documentation
add 6a5494908279 CAMEL-25382: Reduce semantic registry and declaration
overhead
add 6fd800813c38 CAMEL-25382: Fix JBang validation of semantic
documentation
add 03d215da95cf CAMEL-25382: Address semantic validation review nits
add 921bea1b1420 CAMEL-25382: Isolate semantic replacement validation
add 7c0fca7a09cb CAMEL-25382: Validate predicates registered during
replacement
add 98da02dae0c7 chore: camel-jbang docs - say the Camel CLI is a
development only tool (#27551)
add 53c691058494 CAMEL-25029: camel-kafka-share - consumer for Kafka share
groups (KIP-932) (#27495)
add 155e967efb82 chore: camel-kafka - share the changelog topic handling
of the Kafka repositories
add e03833a795e4 CAMEL-25429: route topology - error paths are not calls
between routes (#27557)
add 57228b7af087 CAMEL-25429: camel-jbang - the monitor draws the error
handling in a frame of its own
add a3a873d60969 CAMEL-25429: camel-jbang - the route view shows its error
handling in a frame of its own
add 6b0178fe7d5c CAMEL-25429: camel-jbang - F1 help of the route diagram
describes x
add 8de7e718b15c CAMEL-25429: camel-jbang - monitor docs and MCP tool text
describe the error handling
add 108062167055 CAMEL-25429: camel-jbang - the error frame has no arrows;
a mark on routes with error handling
add 202222fd9137 CAMEL-25429: review nits, the error labels are built once
per widget; drop an unused method
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 (efac61d5f686)
\
N -- N -- N refs/heads/feature/CAMEL-25429-error-layer
(202222fd9137)
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:
.github/actions/labeler/label-config.yml | 1 +
bom/camel-bom/pom.xml | 5 +
catalog/camel-allcomponents/pom.xml | 5 +
.../org/apache/camel/catalog/components.properties | 1 +
.../camel/catalog/components/kafka-share.json | 193 ++
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../org/apache/camel/catalog/docs.properties | 1 +
.../apache/camel/catalog/docs/kafka-component.adoc | 5 +
.../camel/catalog/docs/kafka-share-component.adoc | 220 ++
.../camel/catalog/docs/semantic-language.adoc | 449 ++--
.../camel/catalog/docs/simple-functions.adoc | 8 +
.../org/apache/camel/catalog/docs/switch-eip.adoc | 2 +-
.../camel/catalog/docs/typesafe-ai-component.adoc | 8 +-
.../apache/camel/catalog/languages/semantic.json | 2 +-
.../org/apache/camel/catalog/languages/simple.json | 141 +-
.../camel/catalog/main/important-headers.json | 1 +
.../camel/catalog/schemas/camelYamlDsl-model.json | 82 +-
.../camel/catalog/simple/camel-simple-validator.js | 1 +
.../org/apache/camel/catalog/CamelCatalogTest.java | 2 +-
components/camel-ai/camel-semantic/pom.xml | 2 +-
.../apache/camel/language/semantic/semantic.json | 2 +-
.../services/org/apache/camel/language.properties | 2 +-
.../src/main/docs/semantic-language.adoc | 449 ++--
.../camel/language/semantic/SemanticLanguage.java | 246 ++-
.../org/apache/camel/semantic/SemanticAdapter.java | 28 +-
.../camel/semantic/SemanticCapabilities.java | 508 ++---
.../apache/camel/semantic/SemanticEvaluation.java | 107 +
.../camel/semantic/SemanticEvaluationBuilder.java | 184 ++
.../apache/camel/semantic/SemanticEvaluations.java | 194 ++
...uilder.java => SemanticEvaluationsBuilder.java} | 74 +-
.../org/apache/camel/semantic/SemanticExpert.java | 38 +-
.../apache/camel/semantic/SemanticOperation.java | 74 +
.../apache/camel/semantic/SemanticParameter.java | 58 +
.../apache/camel/semantic/SemanticQuestion.java | 133 --
.../camel/semantic/SemanticQuestionBuilder.java | 161 --
.../apache/camel/semantic/SemanticQuestions.java | 148 --
.../camel/semantic/SemanticReloadPlugin.java | 15 +-
.../org/apache/camel/semantic/SemanticResult.java | 51 +-
.../apache/camel/semantic/SemanticXmlLoader.java | 10 +-
.../semantic/SemanticXmlRoutesBuilderLoader.java | 131 +-
.../yaml/SemanticDefinitionDeserializer.java | 226 +-
.../apache/camel/semantic/FixedSemanticExpert.java | 84 +
.../apache/camel/semantic/SemanticBatchTest.java | 149 +-
.../camel/semantic/SemanticCapabilitiesTest.java | 207 +-
.../camel/semantic/SemanticContractTest.java | 700 +++++++
.../camel/semantic/SemanticDeclarationDslTest.java | 280 +--
.../org/apache/camel/semantic/SemanticEipTest.java | 38 +-
.../semantic/SemanticEvaluationBuilderTest.java | 144 ++
.../apache/camel/semantic/SemanticExpertTest.java | 222 +-
.../camel/semantic/SemanticExpertYamlTest.java | 69 +-
.../camel/semantic/SemanticInitializationTest.java | 67 +-
.../camel/semantic/SemanticLanguageTest.java | 138 +-
.../camel/semantic/SemanticPropertiesTest.java | 12 +-
.../apache/camel/semantic/SemanticResultTest.java | 49 +-
.../semantic/SemanticRetryAndValidationTest.java | 24 +-
.../semantic/SemanticXmlAutoDiscoveryTest.java | 39 +-
.../camel/semantic/SemanticXmlLoaderTest.java | 10 +-
.../apache/camel/semantic/TestSemanticAdapter.java | 110 +
.../src/main/docs/typesafe-ai-component.adoc | 8 +-
.../typesafeai/TypeSafeAiSemanticAdapter.java | 180 +-
.../typesafeai/TypeSafeAiApiPathTest.java | 13 +-
.../typesafeai/TypeSafeAiSemanticAdapterTest.java | 202 +-
.../component/kafka/AbstractKafkaComponent.java | 40 +-
.../component/kafka/KafkaClientConfiguration.java | 9 +-
.../component/kafka/KafkaReconnectSupport.java | 57 +
.../camel-semantic => camel-kafka-share}/pom.xml | 49 +-
.../kafka/share/KafkaShareComponentConfigurer.java | 534 +++++
.../kafka/share/KafkaShareEndpointConfigurer.java | 489 +++++
.../kafka/share/KafkaShareEndpointUriFactory.java | 159 ++
.../camel/component/kafka/share/kafka-share.json | 193 ++
.../services/org/apache/camel/component.properties | 7 +
.../org/apache/camel/component/kafka-share | 2 +
.../apache/camel/configurer/kafka-share-component | 2 +
.../apache/camel/configurer/kafka-share-endpoint | 2 +
.../apache/camel/urifactory/kafka-share-endpoint | 2 +
.../src/main/docs/kafka-share-component.adoc | 220 ++
.../share/DefaultKafkaShareClientFactory.java | 41 +
.../kafka/share/KafkaShareAcknowledgeType.java | 49 +
.../kafka/share/KafkaShareClientFactory.java | 45 +
.../kafka/share/KafkaShareCommitMode.java | 32 +
.../component/kafka/share/KafkaShareComponent.java | 103 +
.../kafka/share/KafkaShareConfiguration.java | 344 +++
.../component/kafka/share/KafkaShareConstants.java | 49 +
.../component/kafka/share/KafkaShareConsumer.java | 158 ++
.../kafka/share/KafkaShareConsumerHealthCheck.java | 67 +
.../component/kafka/share/KafkaShareEndpoint.java | 176 ++
.../kafka/share/KafkaShareFetchRecords.java | 452 ++++
.../kafka/share/KafkaShareComponentTest.java | 88 +
.../kafka/share/KafkaShareConfigurationTest.java | 94 +
.../kafka/share/KafkaShareConsumerErrorTest.java | 239 +++
.../kafka/share/KafkaShareConsumerTest.java | 135 ++
.../kafka/share/RecordingShareConsumer.java | 139 ++
.../share/integration/KafkaShareConsumerIT.java | 186 ++
.../src/test/resources/log4j2.properties | 32 +
.../org/apache/camel/component/kafka/kafka.json | 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 5 +
.../camel/component/kafka/KafkaComponent.java | 19 +-
.../camel/component/kafka/KafkaFetchRecords.java | 15 +-
.../processor/idempotent/kafka/KafkaChangelog.java | 273 +++
.../kafka/KafkaIdempotentRepository.java | 161 +-
.../keyvalue/kafka/KafkaKeyValueRepository.java | 162 +-
.../kafka/KafkaIdempotentRepositoryTest.java | 15 +-
components/pom.xml | 1 +
.../main/docs/modules/eips/pages/switch-eip.adoc | 2 +-
.../org/apache/camel/language/simple/simple.json | 141 +-
.../modules/languages/pages/simple-functions.adoc | 8 +
.../camel/language/simple/SimpleConstants.java | 6 +
.../language/simple/SimplePredicateExpression.java | 34 +
.../camel/language/simple/SimpleSyntaxHints.java | 9 +-
.../simple/ast/SimpleFunctionExpression.java | 9 +-
.../camel/language/simple/ast/UnaryExpression.java | 11 +-
.../functions/QueryLanguageFunctionFactory.java | 49 +
.../language/simple/SimpleNotOperatorTest.java | 47 +
.../language/simple/SimpleSyntaxHintsTest.java | 8 +
.../org/apache/camel/main/components.properties | 1 +
.../java/org/apache/camel/util/ArtifactUtils.java | 1 +
.../apache/camel/util/ImportantHeaderUtils.java | 1 +
.../java/org/apache/camel/util/SecurityUtils.java | 1 +
.../java/org/apache/camel/util/SimpleUtils.java | 1 +
.../modules/ROOT/examples/json/kafka-share.json | 1 +
docs/components/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/kafka-share-component.adoc | 1 +
.../modules/ROOT/pages/camel-jbang.adoc | 12 +
.../component/ComponentsBuilderFactory.java | 14 +
.../dsl/KafkaComponentBuilderFactory.java | 2 +-
.../dsl/KafkaShareComponentBuilderFactory.java | 1638 +++++++++++++++
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/EndpointHeaderBuilders.java | 14 +
.../builder/endpoint/StaticEndpointBuilders.java | 44 +
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 12 +-
.../dsl/KafkaShareEndpointBuilderFactory.java | 2185 ++++++++++++++++++++
.../dsl/jbang/core/commands/ai/eip-samples.json | 2 +-
.../dsl/jbang/core/commands/RouteDslConverter.java | 2 +-
.../dsl/jbang/core/commands/ai/SimpleChecks.java | 1 +
.../jbang/core/commands/RouteDslConverterTest.java | 4 +-
.../core/commands/ai/CatalogDocExcerptTest.java | 4 +-
.../commands/ai/SourceValidatorSimpleTest.java | 57 +
.../core/commands/mcp/TransformToolsTest.java | 8 +-
.../camel-component-known-dependencies.properties | 1 +
.../dsl/yaml/validator/SemanticSchemaTest.java | 90 +-
.../resources/schema/camelYamlDsl-canonical.json | 95 +-
.../resources/schema/camelYamlDsl-model.json | 82 +-
.../generated/resources/schema/camelYamlDsl.json | 95 +-
.../camel/dsl/yaml/YamlRoutesBuilderLoader.java | 12 +-
...estionTest.java => SemanticEvaluationTest.java} | 322 ++-
parent/pom.xml | 5 +
.../services/ContainerLocalKafkaInfraService.java | 15 +-
.../infra/kafka/services/KafkaServiceFactory.java | 2 +-
149 files changed, 13813 insertions(+), 2805 deletions(-)
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka-share.json
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kafka-share-component.adoc
create mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticEvaluation.java
create mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticEvaluationBuilder.java
create mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticEvaluations.java
rename
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/{SemanticQuestionsBuilder.java
=> SemanticEvaluationsBuilder.java} (59%)
create mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticOperation.java
create mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticParameter.java
delete mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticQuestion.java
delete mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticQuestionBuilder.java
delete mode 100644
components/camel-ai/camel-semantic/src/main/java/org/apache/camel/semantic/SemanticQuestions.java
create mode 100644
components/camel-ai/camel-semantic/src/test/java/org/apache/camel/semantic/FixedSemanticExpert.java
create mode 100644
components/camel-ai/camel-semantic/src/test/java/org/apache/camel/semantic/SemanticContractTest.java
create mode 100644
components/camel-ai/camel-semantic/src/test/java/org/apache/camel/semantic/SemanticEvaluationBuilderTest.java
create mode 100644
components/camel-ai/camel-semantic/src/test/java/org/apache/camel/semantic/TestSemanticAdapter.java
create mode 100644
components/camel-kafka-common/src/main/java/org/apache/camel/component/kafka/KafkaReconnectSupport.java
copy components/{camel-ai/camel-semantic => camel-kafka-share}/pom.xml (64%)
create mode 100644
components/camel-kafka-share/src/generated/java/org/apache/camel/component/kafka/share/KafkaShareComponentConfigurer.java
create mode 100644
components/camel-kafka-share/src/generated/java/org/apache/camel/component/kafka/share/KafkaShareEndpointConfigurer.java
create mode 100644
components/camel-kafka-share/src/generated/java/org/apache/camel/component/kafka/share/KafkaShareEndpointUriFactory.java
create mode 100644
components/camel-kafka-share/src/generated/resources/META-INF/org/apache/camel/component/kafka/share/kafka-share.json
create mode 100644
components/camel-kafka-share/src/generated/resources/META-INF/services/org/apache/camel/component.properties
create mode 100644
components/camel-kafka-share/src/generated/resources/META-INF/services/org/apache/camel/component/kafka-share
create mode 100644
components/camel-kafka-share/src/generated/resources/META-INF/services/org/apache/camel/configurer/kafka-share-component
create mode 100644
components/camel-kafka-share/src/generated/resources/META-INF/services/org/apache/camel/configurer/kafka-share-endpoint
create mode 100644
components/camel-kafka-share/src/generated/resources/META-INF/services/org/apache/camel/urifactory/kafka-share-endpoint
create mode 100644
components/camel-kafka-share/src/main/docs/kafka-share-component.adoc
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/DefaultKafkaShareClientFactory.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareAcknowledgeType.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareClientFactory.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareCommitMode.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareComponent.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareConfiguration.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareConstants.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareConsumer.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareConsumerHealthCheck.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareEndpoint.java
create mode 100644
components/camel-kafka-share/src/main/java/org/apache/camel/component/kafka/share/KafkaShareFetchRecords.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/KafkaShareComponentTest.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/KafkaShareConfigurationTest.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/KafkaShareConsumerErrorTest.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/KafkaShareConsumerTest.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/RecordingShareConsumer.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/integration/KafkaShareConsumerIT.java
create mode 100644
components/camel-kafka-share/src/test/resources/log4j2.properties
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaChangelog.java
create mode 100644
core/camel-core-languages/src/main/java/org/apache/camel/language/simple/SimplePredicateExpression.java
create mode 120000 docs/components/modules/ROOT/examples/json/kafka-share.json
create mode 120000
docs/components/modules/ROOT/pages/kafka-share-component.adoc
create mode 100644
dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaShareComponentBuilderFactory.java
create mode 100644
dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KafkaShareEndpointBuilderFactory.java
rename
dsl/camel-yaml-dsl/camel-yaml-dsl/src/test/java/org/apache/camel/dsl/yaml/{SemanticQuestionTest.java
=> SemanticEvaluationTest.java} (50%)
