You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2024/02/08 14:29:02 UTC
(camel) branch regen_bot updated (d610743ccc9 -> 22151ef9e2a)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git
from d610743ccc9 CAMEL-20396: Enable KuduClient to be autowired
add 4ecae317229 CAMEL-20355: refactor the throttle definition
add 046c88ef95d CAMEL-20355: refactor the throttle tests
add bbf8a54414d CAMEL-20355: refactor the throttler
add 22151ef9e2a CAMEL-20355: enable multiple throttling modes
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/models/throttle.json | 12 +-
.../apache/camel/catalog/schemas/camel-spring.xsd | 24 ++
.../spring/processor/SpringThrottlerTest.java | 4 +-
.../SpringThrottlerGroupingTest.java | 4 +-
.../SpringThrottlerMethodCallTest.java | 4 +-
.../SpringThrottlerThreadPoolProfileTest.java | 4 +-
.../SpringThrottlingInflightRoutePolicyTest.java | 4 +-
.../spring/processor/ThrottlerGroupingTest.xml | 4 +-
.../spring/processor/ThrottlerMethodCallTest.xml | 2 +-
.../main/docs/modules/eips/pages/throttle-eip.adoc | 74 ++++
.../resources/org/apache/camel/model/jaxb.index | 1 +
.../resources/org/apache/camel/model/throttle.json | 12 +-
.../apache/camel/model/ProcessorDefinition.java | 1 -
.../org/apache/camel/model/ThrottleDefinition.java | 165 +++++++-
.../org/apache/camel/model/ThrottlingMode.java} | 33 +-
.../apache/camel/processor/AbstractThrottler.java | 153 +++++++
...ttler.java => ConcurrentRequestsThrottler.java} | 121 +-----
.../java/org/apache/camel/processor/Throttler.java | 459 +--------------------
.../camel/processor/TotalRequestsThrottler.java | 388 +++++++++++++++++
.../org/apache/camel/reifier/ThrottleReifier.java | 41 +-
.../ThrottlerInvalidConfiguredTest.java | 2 +-
.../{ => throttle}/ThrottlerNullEvalTest.java | 2 +-
.../{ => throttle}/ThrottlerPermitTest.java | 2 +-
.../ThrottlerThreadPoolProfileTest.java | 2 +-
.../{ => throttle}/ThrottlingException.java | 2 +-
...xceptionRoutePolicyHalfOpenHandlerSedaTest.java | 2 +-
...ingExceptionRoutePolicyHalfOpenHandlerTest.java | 2 +-
...ThrottlingExceptionRoutePolicyHalfOpenTest.java | 2 +-
...lingExceptionRoutePolicyKeepOpenOnInitTest.java | 2 +-
...tlingExceptionRoutePolicyOpenViaConfigTest.java | 2 +-
.../ThrottlingExceptionRoutePolicyTest.java | 2 +-
.../ThrottlingInflightRoutePolicyTest.java | 2 +-
.../ConcurrentRequestsThrottlerTest.java} | 16 +-
.../ThrottlerAsyncDelayedCallerRunsTest.java | 4 +-
.../concurrent}/ThrottlerAsyncDelayedTest.java | 8 +-
.../concurrent}/ThrottlerMethodCallTest.java | 5 +-
.../concurrent}/ThrottlingGroupingTest.java | 13 +-
.../ThrottlerAsyncDelayedCallerRunsTest.java | 4 +-
.../requests}/ThrottlerAsyncDelayedTest.java | 6 +-
.../{ => throttle/requests}/ThrottlerDslTest.java | 11 +-
.../{ => throttle/requests}/ThrottlerTest.java | 190 ++++-----
.../requests}/ThrottlingGroupingTest.java | 167 ++++----
.../management/mbean/ManagedThrottlerMBean.java | 13 +-
.../camel/management/mbean/ManagedThrottler.java | 35 +-
...Test.java => AbstractManagedThrottlerTest.java} | 83 +---
.../management/ManagedConcurrentThrottlerTest.java | 107 +++++
.../camel/management/ManagedThrottlerTest.java | 228 +---------
.../java/org/apache/camel/xml/in/ModelParser.java | 2 +
.../java/org/apache/camel/xml/out/ModelWriter.java | 2 +
.../org/apache/camel/yaml/out/ModelWriter.java | 2 +
.../ROOT/pages/camel-4x-upgrade-guide-4_4.adoc | 16 +
.../dsl/yaml/deserializers/ModelDeserializers.java | 14 +-
.../generated/resources/schema/camelYamlDsl.json | 13 +
53 files changed, 1334 insertions(+), 1139 deletions(-)
rename components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/{ => throttle}/SpringThrottlerGroupingTest.java (94%)
rename components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/{ => throttle}/SpringThrottlerMethodCallTest.java (90%)
rename components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/{ => throttle}/SpringThrottlerThreadPoolProfileTest.java (90%)
rename components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/{ => throttle}/SpringThrottlingInflightRoutePolicyTest.java (90%)
copy core/{camel-core/src/test/java/org/apache/camel/processor/ThrottlingException.java => camel-core-model/src/main/java/org/apache/camel/model/ThrottlingMode.java} (53%)
create mode 100644 core/camel-core-processor/src/main/java/org/apache/camel/processor/AbstractThrottler.java
copy core/camel-core-processor/src/main/java/org/apache/camel/processor/{Throttler.java => ConcurrentRequestsThrottler.java} (78%)
create mode 100644 core/camel-core-processor/src/main/java/org/apache/camel/processor/TotalRequestsThrottler.java
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlerInvalidConfiguredTest.java (97%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlerNullEvalTest.java (98%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlerPermitTest.java (98%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlerThreadPoolProfileTest.java (97%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingException.java (96%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingExceptionRoutePolicyHalfOpenHandlerSedaTest.java (99%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingExceptionRoutePolicyHalfOpenHandlerTest.java (99%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingExceptionRoutePolicyHalfOpenTest.java (99%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingExceptionRoutePolicyKeepOpenOnInitTest.java (98%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingExceptionRoutePolicyOpenViaConfigTest.java (98%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingExceptionRoutePolicyTest.java (99%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle}/ThrottlingInflightRoutePolicyTest.java (97%)
copy core/camel-core/src/test/java/org/apache/camel/processor/{ThrottlerTest.java => throttle/concurrent/ConcurrentRequestsThrottlerTest.java} (93%)
copy core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/concurrent}/ThrottlerAsyncDelayedCallerRunsTest.java (91%)
copy core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/concurrent}/ThrottlerAsyncDelayedTest.java (87%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/concurrent}/ThrottlerMethodCallTest.java (95%)
copy core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/concurrent}/ThrottlingGroupingTest.java (94%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/requests}/ThrottlerAsyncDelayedCallerRunsTest.java (92%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/requests}/ThrottlerAsyncDelayedTest.java (89%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/requests}/ThrottlerDslTest.java (88%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/requests}/ThrottlerTest.java (52%)
rename core/camel-core/src/test/java/org/apache/camel/processor/{ => throttle/requests}/ThrottlingGroupingTest.java (55%)
copy core/camel-management/src/test/java/org/apache/camel/management/{ManagedThrottlerTest.java => AbstractManagedThrottlerTest.java} (73%)
create mode 100644 core/camel-management/src/test/java/org/apache/camel/management/ManagedConcurrentThrottlerTest.java