This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26064-as2-mute-exception
in repository https://gitbox.apache.org/repos/asf/camel.git
discard a510354d812f Merge remote-tracking branch 'origin/main' into
CAMEL-26064-as2-mute-exception
discard e5aeceb045d0 CAMEL-26064: camel-as2 - add the muteException option to
the server and receipt consumers, true by default
add 6392ce54180b CAMEL-25955: watchesFile ignores JVM options with
wildcards to fix flaky test (#28304)
add ed3d719b379c chore: upgrade guide - the pqc note about signing message
bodies over their bytes is part of 4.22.3
add 255772f0de44 chore: camel-jbang - source editor: a note on a line that
sends to a direct: or seda: endpoint no route consumes (#28342)
add c78e59f0df66 CAMEL-25964: camel-vertx - VertxHelper does not apply
standalone TrustManager from SSLContextParameters (#28305)
add cb73720780f9 CAMEL-25918: camel-as2 - consumers sharing a port use
their own asynchronous MDN settings (#28274)
add 1478bac65753 chore(deps): Bump jackson2-version from 2.22.3 to 2.22.4
(#28290)
add 67e73b3cb425 chore: camel-jbang - source editor: a note for a direct:
or seda: endpoint no route consumes on Java and XML routes too
add 9869dd004979 chore: camel-aws2-step-functions - the operation option
listed the operations of aws2-lambda
add ec5d16cdbf79 chore(ci): use nats 2.15.0 instead of 2.15.1 for ppc64le
add 223ecca4442a CAMEL-25851: camel-paho-mqtt5 - consumers that share a
client each get the messages of their own topic (#28324)
add 7b58ce0cdaf6 CAMEL-25488: camel-jgroups-raft - tests close their
channels and report the state of the nodes when no leader is elected (#28243)
add b649901c4c2b chore(deps): Bump grpc-version from 1.85.0 to 1.85.1
add 36bebb520a63 chore(deps): Bump httpclient-version from 5.6.4 to 5.6.5
add 9aee81df989a CAMEL-25815: camel-nats - the JetStream pull consumer
subscribes again when the server deleted its consumer (#28204)
add adf38d969ea8 CAMEL-25846: camel-tahu - an Edge Node producer connects
again after its route is restarted (#28319)
add a4f2532b4262 CAMEL-25848: camel-quartz - a scheduled resume or start
starts a consumer that the scheduled suspend stopped (#28321)
add d761ff850947 CAMEL-25852: camel-jgroups - an endpoint no longer
disconnects or closes the channel of the component while other endpoints use it
(#28325)
add b1c3c9212a05 chore(deps): Bump the kamelet group with 2 updates
(#28338)
add 330754002072 CAMEL-25694: camel-milo - fix write/call service failures
being reported as success (#27956)
add 694245fae833 CAMEL-25850: camel-jetty - stopping one Jetty server
stops only its own thread pool (#28323)
add dc990927b60e CAMEL-26068: camel-netty-http - Ensure
NettyHttpSecurityConfiguration is copied per endpoint (#28351)
add dfd02e66a4d0 CAMEL-25845: camel-nats - the JetStream push consumer
subscribes again when the server deleted its ephemeral consumer (#28318)
add 78c989ec5182 CAMEL-26105: camel-aws2-athena - take the SQL from the
message body only with useMessageBodyForSql (#28356)
add a6e160866de5 CAMEL-26064: camel-as2 - add the muteException option to
the server and receipt consumers, true by default
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 (a510354d812f)
\
N -- N -- N refs/heads/CAMEL-26064-as2-mute-exception
(a6e160866de5)
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:
.../org/apache/camel/catalog/components/as2.json | 8 +-
.../camel/catalog/components/aws2-athena.json | 88 ++-
.../catalog/components/aws2-step-functions.json | 6 +-
.../apache/camel/catalog/docs/as2-component.adoc | 8 +
.../camel/catalog/docs/aws2-athena-component.adoc | 120 ++-
.../apache/camel/catalog/docs/nats-component.adoc | 30 +
.../camel/catalog/docs/tahu-edge-component.adoc | 4 +
.../component/as2/api/AS2ServerConnection.java | 90 ++-
.../AS2ConsumerConfigurationMdnSettingsTest.java | 91 +++
.../org/apache/camel/component/as2/as2.json | 8 +-
.../src/main/docs/as2-component.adoc | 8 +
.../camel/component/as2/AS2Configuration.java | 13 +-
.../apache/camel/component/as2/AS2Consumer.java | 28 +-
.../AS2ServerTwoConsumerAsyncMdnSettingsTest.java | 170 ++++
.../aws2/athena/Athena2ComponentConfigurer.java | 6 +
.../aws2/athena/Athena2EndpointConfigurer.java | 6 +
.../aws2/athena/Athena2EndpointUriFactory.java | 3 +-
.../camel/component/aws2/athena/aws2-athena.json | 88 ++-
.../src/main/docs/aws2-athena-component.adoc | 120 ++-
.../aws2/athena/Athena2Configuration.java | 29 +-
.../component/aws2/athena/Athena2Constants.java | 4 +-
.../component/aws2/athena/Athena2Producer.java | 18 +-
.../aws2/athena/AmazonAthenaClientMock.java | 10 +
.../athena/Athena2ProducerQueryStringTest.java | 158 ++++
.../athena/AthenaComponentConfigurationTest.java | 18 +
.../component/aws2/athena/AthenaComponentTest.java | 2 +-
.../component/aws2/athena/AthenaEndpointTest.java | 3 +
.../integration/AthenaComponentManualIT.java | 38 +-
.../aws2/stepfunctions/aws2-step-functions.json | 6 +-
.../stepfunctions/StepFunctions2Configuration.java | 2 +-
.../stepfunctions/StepFunctions2Constants.java | 2 +-
.../camel/component/jetty/JettyHttpComponent.java | 46 +-
.../jetty/JettyThreadPoolTwoServersTest.java | 96 +++
.../jgroups/raft/JGroupsRaftAbstractTest.java | 37 +-
.../component/jgroups/raft/RaftNodesState.java | 44 ++
.../cluster/JGroupsRaftClusterAbstractTest.java | 81 +-
.../JGroupsRaftClusteredRoutePolicyTest.java | 52 +-
.../raft/cluster/JGroupsRaftMasterTest.java | 58 +-
.../camel/component/jgroups/JGroupsComponent.java | 71 ++
.../camel/component/jgroups/JGroupsConsumer.java | 17 +-
.../camel/component/jgroups/JGroupsEndpoint.java | 58 +-
.../camel/component/jgroups/JGroupsProducer.java | 9 +-
.../JGroupsComponentChannelEndpointsTest.java | 151 ++++
.../jgroups/JGroupsEndpointOwnChannelTest.java | 161 ++++
.../milo/client/internal/SubscriptionManager.java | 20 +-
.../camel/component/milo/call/CallClientTest.java | 15 +
.../client/MiloClientProducerWriteFailureTest.java | 221 ++++++
...ubscriptionManagerExceptionPropagationTest.java | 203 +++++
.../camel-nats/src/main/docs/nats-component.adoc | 30 +
.../camel/component/nats/DefaultNatsManualAck.java | 6 +-
.../apache/camel/component/nats/NatsConsumer.java | 276 ++++++-
.../nats/NatsJetStreamPushConsumerKeeper.java | 393 ++++++++++
.../nats/NatsConsumerPullConsumerDeletedTest.java | 421 ++++++++++
.../nats/NatsConsumerPullConsumerGoneTest.java | 263 +++++++
.../nats/NatsConsumerPushConsumerDeletedTest.java | 866 +++++++++++++++++++++
.../NatsJetstreamConsumerPullDeletedIT.java | 107 +++
.../component/netty/http/NettyHttpComponent.java | 6 +-
.../netty/http/NettyHttpSecurityConfiguration.java | 16 +-
.../NettyHttpSharedSecurityConfigurationTest.java | 116 +++
.../paho/mqtt5/PahoMqtt5ClientCallback.java | 224 ++++++
.../component/paho/mqtt5/PahoMqtt5Consumer.java | 122 +--
.../mqtt5/PahoMqtt5ClientCallbackMatchesTest.java | 77 ++
.../mqtt5/PahoMqtt5SharedClientConsumersTest.java | 234 ++++++
.../mqtt5/PahoMqtt5SharedClientReconnectTest.java | 65 ++
.../camel/component/paho/PahoClientCallback.java | 214 +++++
.../apache/camel/component/paho/PahoConsumer.java | 102 +--
.../paho/PahoClientCallbackMatchesTest.java | 77 ++
.../paho/PahoSharedClientConsumersTest.java | 243 ++++++
.../paho/PahoSharedClientReconnectTest.java | 66 ++
.../routepolicy/quartz/ScheduledRoutePolicy.java | 76 +-
...duledRoutePolicyNonSuspendableConsumerTest.java | 271 +++++++
.../src/main/docs/tahu-edge-component.adoc | 4 +
.../camel/component/tahu/TahuEdgeProducer.java | 145 +++-
.../component/tahu/handlers/TahuEdgeClient.java | 7 +
.../camel/component/tahu/FakeMqttBroker.java | 168 ++++
.../tahu/TahuEdgeProducerRestartTest.java | 249 ++++++
components/camel-vertx/camel-vertx-common/pom.xml | 12 +
.../camel/component/vertx/common/VertxHelper.java | 375 ++++-----
.../component/vertx/common/VertxHelperTest.java | 132 ++++
.../src/test/resources/jsse}/truststore.jks | Bin
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 30 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 114 +++
.../ROOT/pages/camel-jbang-tui-source-editor.adoc | 7 +
.../dsl/Aws2AthenaComponentBuilderFactory.java | 30 +-
.../Aws2StepFunctionsComponentBuilderFactory.java | 3 +-
.../endpoint/dsl/AS2EndpointBuilderFactory.java | 42 +-
.../dsl/Athena2EndpointBuilderFactory.java | 51 +-
.../dsl/StepFunctions2EndpointBuilderFactory.java | 8 +-
.../core/commands/ai/EndpointConsumerChecks.java | 66 +-
.../core/commands/ai/IntegrationLauncher.java | 7 +-
.../dsl/jbang/core/commands/ai/ModelChecks.java | 13 +
.../ai/SourceValidatorEndpointConsumersTest.java | 82 ++
dsl/camel-jbang/camel-jbang-plugin-tui/AGENTS.md | 2 +-
.../jbang/core/commands/tui/ConsumedEndpoints.java | 155 ++++
.../dsl/jbang/core/commands/tui/SourceChecks.java | 181 +++++
.../jbang/core/commands/tui/SourceEditAssist.java | 6 +-
.../dsl/jbang/core/commands/tui/SourceTab.java | 18 +-
.../dsl/jbang/core/commands/tui/SourceViewer.java | 202 ++---
.../src/main/resources/tui/help/source.md | 4 +
.../jbang/core/commands/tui/SourceChecksTest.java | 99 +++
.../core/commands/tui/SourceConsumerNotesTest.java | 274 +++++++
.../commands/tui/SourceKameletValidationTest.java | 2 +-
.../jbang/core/commands/tui/SourceSizeTest.java | 2 +-
dsl/camel-jbang/camel-launcher/pom.xml | 2 +-
parent/pom.xml | 8 +-
.../test/infra/nats/services/container.properties | 2 +
106 files changed, 8407 insertions(+), 891 deletions(-)
create mode 100644
components/camel-as2/camel-as2-api/src/test/java/org/apache/camel/component/as2/api/AS2ConsumerConfigurationMdnSettingsTest.java
create mode 100644
components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ServerTwoConsumerAsyncMdnSettingsTest.java
create mode 100644
components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerQueryStringTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyThreadPoolTwoServersTest.java
create mode 100644
components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/RaftNodesState.java
create mode 100644
components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsComponentChannelEndpointsTest.java
create mode 100644
components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsEndpointOwnChannelTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/client/MiloClientProducerWriteFailureTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/client/internal/SubscriptionManagerExceptionPropagationTest.java
create mode 100644
components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsJetStreamPushConsumerKeeper.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerPullConsumerDeletedTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerPullConsumerGoneTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerPushConsumerDeletedTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/jetstream/NatsJetstreamConsumerPullDeletedIT.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpSharedSecurityConfigurationTest.java
create mode 100644
components/camel-paho-mqtt5/src/main/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ClientCallback.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ClientCallbackMatchesTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SharedClientConsumersTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SharedClientReconnectTest.java
create mode 100644
components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoClientCallback.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoClientCallbackMatchesTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoSharedClientConsumersTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoSharedClientReconnectTest.java
create mode 100644
components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicyNonSuspendableConsumerTest.java
create mode 100644
components/camel-tahu/src/test/java/org/apache/camel/component/tahu/FakeMqttBroker.java
create mode 100644
components/camel-tahu/src/test/java/org/apache/camel/component/tahu/TahuEdgeProducerRestartTest.java
create mode 100644
components/camel-vertx/camel-vertx-common/src/test/java/org/apache/camel/component/vertx/common/VertxHelperTest.java
copy components/{camel-coap/src/test/resources =>
camel-vertx/camel-vertx-common/src/test/resources/jsse}/truststore.jks (100%)
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/ConsumedEndpoints.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceChecks.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceChecksTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceConsumerNotesTest.java
