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