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 2022/04/13 09:44:45 UTC

[camel] branch regen_bot updated (2de2764a687 -> 28d143047e1)

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


    omit 2de2764a687 CAMEL-17051: extend the Resume API to include support for pausable consumers

This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.

 * -- * -- N   refs/heads/regen_bot (28d143047e1)
            \
             O -- O -- O   (2de2764a687)

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/kafka.json |   4 +-
 .../org/apache/camel/catalog/models.properties     |   1 -
 .../org/apache/camel/catalog/models/pausable.json  |  20 --
 .../apache/camel/catalog/schemas/camel-spring.xsd  |  50 -----
 components/camel-kafka/pom.xml                     |  18 --
 .../component/kafka/KafkaComponentConfigurer.java  |   4 +-
 .../component/kafka/KafkaEndpointConfigurer.java   |   4 +-
 .../org/apache/camel/component/kafka/kafka.json    |   4 +-
 .../camel-kafka/src/main/docs/kafka-component.adoc |  16 --
 .../camel/component/kafka/KafkaConfiguration.java  |  12 +-
 .../camel/component/kafka/KafkaConsumer.java       |  41 +----
 .../camel/component/kafka/KafkaFetchRecords.java   |  65 ++-----
 .../component/kafka/PollExceptionStrategy.java     |  15 --
 .../apache/camel/component/kafka/SeekPolicy.java   |  27 ---
 .../consumer/errorhandler/BridgeErrorStrategy.java |   5 -
 .../errorhandler/DiscardErrorStrategy.java         |   5 -
 .../errorhandler/KafkaConsumerListener.java        |  89 ---------
 .../errorhandler/KafkaErrorStrategies.java         |   2 +-
 .../errorhandler/ReconnectErrorStrategy.java       |  14 +-
 .../consumer/errorhandler/RetryErrorStrategy.java  |  10 +-
 .../consumer/errorhandler/StopErrorStrategy.java   |  13 +-
 .../consumer/support/KafkaRecordProcessor.java     |   4 +-
 .../support/KafkaRecordProcessorFacade.java        |  15 +-
 .../kafka/consumer/support/ProcessingResult.java   |  11 +-
 .../consumer/support/ResumeStrategyFactory.java    |   3 +-
 .../SeekPolicyKafkaConsumerResumeStrategy.java     |   9 +-
 .../integration/BaseEmbeddedKafkaTestSupport.java  |  10 +-
 .../kafka/integration/KafkaConsumerFullIT.java     |   5 +-
 .../integration/pause/KafkaPausableConsumerIT.java | 203 ---------------------
 .../src/test/resources/log4j2.properties           |   2 +-
 .../java/org/apache/camel/ConsumerListener.java    |  52 ------
 .../org/apache/camel/ConsumerListenerAware.java    |  39 ----
 .../src/main/java/org/apache/camel/Route.java      |   5 -
 .../org/apache/camel/impl/engine/DefaultRoute.java |  12 --
 .../docs/modules/eips/examples/json/pausable.json  |   1 -
 .../docs/modules/eips/pages/resume-strategies.adoc |  28 +--
 .../services/org/apache/camel/model.properties     |   1 -
 .../resources/org/apache/camel/model/jaxb.index    |   1 -
 .../resources/org/apache/camel/model/pausable.json |  20 --
 .../org/apache/camel/model/PausableDefinition.java | 115 ------------
 .../apache/camel/model/ProcessorDefinition.java    |  58 ------
 .../apache/camel/processor/PausableProcessor.java  |  99 ----------
 .../org/apache/camel/reifier/PausableReifier.java  |  71 -------
 .../org/apache/camel/reifier/ProcessorReifier.java |   3 -
 .../java/org/apache/camel/xml/in/ModelParser.java  |  11 --
 .../dsl/KafkaComponentBuilderFactory.java          |  13 +-
 .../endpoint/dsl/KafkaEndpointBuilderFactory.java  |  27 +--
 .../dsl/yaml/deserializers/ModelDeserializers.java |  60 ------
 .../deserializers/ModelDeserializersResolver.java  |   2 -
 .../src/generated/resources/camel-yaml-dsl.json    |  24 ---
 .../src/generated/resources/camelYamlDsl.json      |  24 ---
 51 files changed, 70 insertions(+), 1277 deletions(-)
 delete mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/pausable.json
 delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/SeekPolicy.java
 delete mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/KafkaConsumerListener.java
 delete mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerIT.java
 delete mode 100644 core/camel-api/src/main/java/org/apache/camel/ConsumerListener.java
 delete mode 100644 core/camel-api/src/main/java/org/apache/camel/ConsumerListenerAware.java
 delete mode 120000 core/camel-core-engine/src/main/docs/modules/eips/examples/json/pausable.json
 delete mode 100644 core/camel-core-model/src/generated/resources/org/apache/camel/model/pausable.json
 delete mode 100644 core/camel-core-model/src/main/java/org/apache/camel/model/PausableDefinition.java
 delete mode 100644 core/camel-core-processor/src/main/java/org/apache/camel/processor/PausableProcessor.java
 delete mode 100644 core/camel-core-reifier/src/main/java/org/apache/camel/reifier/PausableReifier.java