This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch fix/CAMEL-26013-messaging-bugs
in repository https://gitbox.apache.org/repos/asf/camel.git
discard c9f9a5149aad CAMEL-26013: messaging components - fixes found by the
body type checks
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 f701c7e0416b CAMEL-26013: messaging components - fixes found by the
body type checks
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 (c9f9a5149aad)
\
N -- N -- N refs/heads/fix/CAMEL-26013-messaging-bugs
(f701c7e0416b)
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:
.../camel/catalog/components/aws2-athena.json | 88 ++-
.../camel/catalog/docs/aws2-athena-component.adoc | 120 ++-
.../apache/camel/catalog/docs/nats-component.adoc | 30 +
.../camel/catalog/docs/tahu-edge-component.adoc | 4 +
.../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 +-
.../camel/component/jetty/JettyHttpComponent.java | 46 +-
.../jetty/JettyThreadPoolTwoServersTest.java | 96 +++
.../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 +++
.../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 ++++++
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 63 ++
.../dsl/Aws2AthenaComponentBuilderFactory.java | 30 +-
.../dsl/Athena2EndpointBuilderFactory.java | 51 +-
dsl/camel-jbang/camel-launcher/pom.xml | 2 +-
parent/pom.xml | 2 +-
53 files changed, 5130 insertions(+), 251 deletions(-)
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/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-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
