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 2023/07/28 14:11:00 UTC

[camel] branch regen_bot updated (6cccbfb6f69 -> c08104ee967)

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 6cccbfb6f69 (chores) camel-zookeeper-master: disable tests on ARM (#10884)
     add c08104ee967 kinesis connection retry mechanism added into the current consumer (#10870)

No new revisions were added by this update.

Summary of changes:
 .../component/aws2/kinesis/Kinesis2Consumer.java   | 60 +++++++++++--------
 .../component/aws2/kinesis/Kinesis2Endpoint.java   | 25 +++++---
 .../aws2/kinesis/consumer/KinesisConnection.java   | 70 ++++++++++++++++++++++
 .../aws2/kinesis/consumer/KinesisHealthCheck.java  | 63 +++++++++++++++++++
 .../KinesisConsumerClosedShardWithFailTest.java    | 29 ++++++++-
 .../KinesisConsumerClosedShardWithSilentTest.java  | 48 +++++++++++----
 .../kinesis/integration/KinesisConsumerIT.java     | 23 ++++---
 .../integration/KinesisConsumerResumeIT.java       |  7 ++-
 .../kinesis/integration/KinesisProducerIT.java     |  3 +
 9 files changed, 266 insertions(+), 62 deletions(-)
 create mode 100644 components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/consumer/KinesisConnection.java
 create mode 100644 components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/consumer/KinesisHealthCheck.java