You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/01/10 13:04:30 UTC
(camel) branch main updated (5ed5ec6f75c -> c4711c97301)

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


    from 5ed5ec6f75c Bump io.projectreactor.netty:reactor-netty from 1.1.14 to 1.1.15
     add c4711c97301 CAMEL-20302: Adding JMX control and monitoring for the Dynamic Router EIP component.

No new revisions were added by this update.

Summary of changes:
 .../catalog/components/dynamic-router-control.json |   4 +-
 components/camel-dynamic-router/pom.xml            |  20 +-
 ...RouterControlProducerInvokeOnHeaderFactory.java |   2 +
 ...icRouterControlServiceBulkConverterLoader.java} |   6 +-
 .../services/org/apache/camel/TypeConverterLoader  |   2 +-
 .../control/dynamic-router-control.json            |   4 +-
 .../src/main/docs/dynamic-router-component.adoc    |  79 ++++++
 .../docs/dynamic-router-control-component.adoc     |  81 ++++++-
 .../control/DynamicRouterControlComponent.java     |  43 +++-
 .../control/DynamicRouterControlConstants.java     |  19 +-
 .../control/DynamicRouterControlEndpoint.java      |  87 ++++---
 .../control/DynamicRouterControlMessage.java       |  10 +-
 .../control/DynamicRouterControlProducer.java      | 215 ++++++++---------
 .../control/DynamicRouterControlService.java       | 268 +++++++++++++++++++++
 .../{ => filter}/DynamicRouterFilterService.java   | 112 +++++++--
 .../{ => filter}/PrioritizedFilter.java            |  30 +--
 .../filter/PrioritizedFilterStatistics.java        |  67 ++++++
 .../routing/DynamicRouterComponent.java            |  10 +-
 .../routing/DynamicRouterConstants.java            |   8 +-
 .../routing/DynamicRouterEndpoint.java             |   2 +-
 .../routing/DynamicRouterProcessor.java            |   5 +-
 .../DynamicRouterRecipientListHelper.java          |   3 +-
 .../DynamicRouterFilterServiceTest.java            | 149 ------------
 .../dynamicrouter/DynamicRouterTestConstants.java  |  80 ------
 .../control/DynamicRouterControlComponentTest.java |  41 +++-
 .../control/DynamicRouterControlEndpointTest.java  |  31 +--
 .../control/DynamicRouterControlProducerTest.java  | 227 ++++++++++++-----
 .../control/DynamicRouterControlServiceTest.java   | 157 ++++++++++++
 .../filter/DynamicRouterFilterServiceTest.java     | 233 ++++++++++++++++++
 .../filter/PrioritizedFilterStatisticsTest.java    |  52 ++++
 .../{ => filter}/PrioritizedFilterTest.java        |  26 +-
 .../DynamicRouterBasicSynchronousIT.java           | 100 +++++---
 .../integration/DynamicRouterJmxIT.java            | 259 ++++++++++++++++++++
 .../integration/DynamicRouterMBeansIT.java         | 116 +++++++++
 .../DynamicRouterSendDynamicAwareIT.java           |  63 ++++-
 .../routing/DynamicRouterComponentTest.java        |  20 +-
 .../routing/DynamicRouterEndpointTest.java         |  17 +-
 .../routing/DynamicRouterProcessorTest.java        |  14 +-
 .../routing/DynamicRouterProducerTest.java         |  28 +++
 .../integration/DynamicRouterJmxIT-context.xml     |  44 ++++
 40 files changed, 2125 insertions(+), 609 deletions(-)
 rename components/camel-dynamic-router/src/generated/java/org/apache/camel/component/dynamicrouter/control/{DynamicRouterControlProducerBulkConverterLoader.java => DynamicRouterControlServiceBulkConverterLoader.java} (89%)
 create mode 100644 components/camel-dynamic-router/src/main/java/org/apache/camel/component/dynamicrouter/control/DynamicRouterControlService.java
 rename components/camel-dynamic-router/src/main/java/org/apache/camel/component/dynamicrouter/{ => filter}/DynamicRouterFilterService.java (67%)
 rename components/camel-dynamic-router/src/main/java/org/apache/camel/component/dynamicrouter/{ => filter}/PrioritizedFilter.java (71%)
 create mode 100644 components/camel-dynamic-router/src/main/java/org/apache/camel/component/dynamicrouter/filter/PrioritizedFilterStatistics.java
 rename components/camel-dynamic-router/src/main/java/org/apache/camel/component/dynamicrouter/{ => routing}/DynamicRouterRecipientListHelper.java (99%)
 delete mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/DynamicRouterFilterServiceTest.java
 delete mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/DynamicRouterTestConstants.java
 create mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/control/DynamicRouterControlServiceTest.java
 create mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/filter/DynamicRouterFilterServiceTest.java
 create mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/filter/PrioritizedFilterStatisticsTest.java
 rename components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/{ => filter}/PrioritizedFilterTest.java (72%)
 create mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/integration/DynamicRouterJmxIT.java
 create mode 100644 components/camel-dynamic-router/src/test/java/org/apache/camel/component/dynamicrouter/integration/DynamicRouterMBeansIT.java
 create mode 100644 components/camel-dynamic-router/src/test/resources/org/apache/camel/component/dynamicrouter/integration/DynamicRouterJmxIT-context.xml