This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch fix/CAMEL-24150
in repository https://gitbox.apache.org/repos/asf/camel.git
omit 8df630cd3f69 CAMEL-24151: Warn when MANUAL saga completion is used
without a timeout
omit 877259fdd5a8 CAMEL-24151: Fix medium and low findings from Saga EIP
code review
omit 45ab56b132c0 CAMEL-24150: Do not stop shared saga service from
individual route processor
add d3009ac5b1d3 CAMEL-24142: Fix Multicast/Split timeout silently lost
when fired during aggregation
add 19d353b00e6e CAMEL-24138: Splitter - Fix failure tracker leaking into
nested splits
add f0a2b69bce24 CAMEL-24139: Fix Splitter watermark advancing past
unrouted items on streaming abort
add ec619f2e17df CAMEL-24147: camel-lra - URL-encode callback query
parameters and fix parseQuery split
add 556cd5ad88f3 chore(deps): Bump com.google.genai:google-genai from
1.61.0 to 1.62.0
add 60b64d24d22d chore(deps): Bump com.prowidesoftware:pw-iso20022
add e33d94723ac7 chore(deps): Bump io.smallrye.config:smallrye-config
add 2517714b0c1d chore(deps): Bump
com.googlecode.libphonenumber:libphonenumber
add beaed8f5035b chore(deps-dev): Bump com.icegreen:greenmail from 2.1.10
to 2.1.11
add 4d93dcf931c5 CAMEL-24126 - Ensure no message sent before the
VertxWebsocket is fully configured
add f7241282eb21 CAMEL-24191: camel-aws2-kinesis - fix KCL consumer
session credentials and checkpoint/error handling (#24835)
add 81cee8e98be8 CAMEL-24085: Apply header filter strategy to IronMQ
message envelope headers (#24828)
add 76fe38979d9a chore(deps): Bump milo-version from 1.1.4 to 1.1.5
add c5c2f74c4b63 CAMEL-24140: Fix UseOriginalAggregationStrategy not
honored when shareUnitOfWork enabled
add a38ed8bea182 CAMEL-24144: InMemorySagaService - Remove coordinators
from map after completion or compensation
add e833ea86fe9e CAMEL-24145: camel-saga - InMemorySagaCoordinator
compensate/complete now propagate finalization outcome
add 4b9ece08c9dd CAMEL-24146: Fix FluentProducerTemplate leak in
InMemorySagaCoordinator
add b7cfc0f148a2 CAMEL-24148: Fix saga option values overwritten on
repeated step enlistment
add e64f46ee149f CAMEL-24149: camel-saga - SagaProducer reads
ExchangeExtension first, survives removeHeaders
add 49848d789867 CAMEL-24150: Do not stop shared saga service from
individual route processor
add 4ce237ef75ec CAMEL-24151: Fix medium and low findings from Saga EIP
code review
add 79ed90db0fbd CAMEL-24151: Warn when MANUAL saga completion is used
without a timeout
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 (8df630cd3f69)
\
N -- N -- N refs/heads/fix/CAMEL-24150 (79ed90db0fbd)
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:
.../aws2/kinesis/KclKinesis2Consumer.java | 47 +++++----
.../KclKinesis2ConsumerRecordProcessingTest.java | 104 +++++++++++++++++++
.../apache/camel/component/ironmq/GsonUtil.java | 9 +-
...st.java => IronMQConsumerHeaderFilterTest.java} | 37 ++++---
.../apache/camel/service/lra/LRASagaRoutes.java | 4 +-
.../apache/camel/service/lra/LRAUrlBuilder.java | 8 +-
.../camel/service/lra/LRASagaRoutesTest.java | 30 ++++++
.../camel/service/lra/LRAUrlBuilderTest.java | 110 ++++++++++++++++++++
.../component/milo/browse/MiloBrowseEndpoint.java | 4 +-
.../milo/client/internal/SubscriptionManager.java | 6 +-
.../component/milo/server/internal/CallMethod.java | 6 +-
.../milo/server/internal/CamelNamespace.java | 12 +--
.../component/milo/browse/BrowseServerTest.java | 6 +-
.../camel/component/milo/call/MockCallMethod.java | 6 +-
.../component/milo/call/MockCamelNamespace.java | 10 +-
.../apache/camel/component/saga/SagaProducer.java | 8 +-
.../websocket/VertxWebsocketClientConsumer.java | 4 +-
.../vertx/websocket/VertxWebsocketEndpoint.java | 23 ++++-
.../apache/camel/processor/MulticastProcessor.java | 55 +++++-----
.../java/org/apache/camel/processor/Splitter.java | 38 ++++---
.../org/apache/camel/reifier/MulticastReifier.java | 6 --
.../apache/camel/reifier/RecipientListReifier.java | 6 --
.../org/apache/camel/reifier/SplitReifier.java | 5 -
.../saga/SagaProducerRemoveHeadersTest.java | 69 +++++++++++++
...ticastParallelTimeoutDuringAggregationTest.java | 97 +++++++++++++++++
.../MulticastUseOriginalShareUnitOfWorkTest.java | 86 +++++++++++++++
...ecipientListUseOriginalShareUnitOfWorkTest.java | 85 +++++++++++++++
.../processor/SagaCoordinatorCleanupTest.java | 101 ++++++++++++++++++
.../apache/camel/processor/SagaFailuresTest.java | 21 ++++
.../apache/camel/processor/SagaOptionsTest.java | 40 +++++++
.../apache/camel/processor/SagaTimeoutTest.java | 6 +-
...va => SplitUseOriginalShareUnitOfWorkTest.java} | 35 +++++--
.../SplitterNestedFailureTrackerLeakTest.java | 115 +++++++++++++++++++++
.../camel/processor/SplitterWatermarkTest.java | 30 ++++++
.../apache/camel/saga/InMemorySagaCoordinator.java | 101 ++++++++++--------
.../org/apache/camel/saga/InMemorySagaService.java | 18 ++++
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 27 +++++
parent/pom.xml | 12 +--
38 files changed, 1205 insertions(+), 182 deletions(-)
create mode 100644
components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KclKinesis2ConsumerRecordProcessingTest.java
copy
components/camel-ironmq/src/test/java/org/apache/camel/component/ironmq/{IronMQPreserveHeadersTest.java
=> IronMQConsumerHeaderFilterTest.java} (55%)
create mode 100644
components/camel-lra/src/test/java/org/apache/camel/service/lra/LRAUrlBuilderTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/component/saga/SagaProducerRemoveHeadersTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelTimeoutDuringAggregationTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/MulticastUseOriginalShareUnitOfWorkTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/RecipientListUseOriginalShareUnitOfWorkTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/SagaCoordinatorCleanupTest.java
copy
core/camel-core/src/test/java/org/apache/camel/processor/{ThreadsRejectedPolicyTest.java
=> SplitUseOriginalShareUnitOfWorkTest.java} (51%)
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/SplitterNestedFailureTrackerLeakTest.java
