You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@sling.apache.org by cs...@apache.org on 2019/12/23 13:58:00 UTC

[sling-org-apache-sling-distribution-journal] branch SLING-8908 updated (8ac538d -> 1406a00)

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

cschneider pushed a change to branch SLING-8908
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git.


    from 8ac538d  SLING-8908 - Mark skipped packages as processed
     add d97a768  SLING-8934 Create new metric for the number of subscribers of distribution publisher (#18)
     add e88d623  SLING-8932 - Redesign DistributionSubscriber to offload responsibilities (#17)
     add f12c220  SLING-8944 - Systemready check for idle subscriber (#19)
     add 1406a00  Merge branch 'master' into SLING-8908

No new revisions were added by this update.

Summary of changes:
 pom.xml                                            |   5 +
 .../impl/publisher/DistributionPublisher.java      |  10 +
 .../impl/shared/DistributionMetricsService.java    |   2 +-
 .../journal/impl/subscriber/Announcer.java         |  38 +-
 .../journal/impl/subscriber/BookKeeper.java        | 335 +++++++++++++
 .../journal/impl/subscriber/CommandPoller.java     | 104 ++++
 .../impl/subscriber/DistributionSubscriber.java    | 541 ++++-----------------
 .../journal/impl/subscriber/PackageHandler.java    |  89 ++++
 .../journal/impl/subscriber/SubscriberIdle.java    |  95 ++++
 .../journal/impl/subscriber/AnnouncerTest.java     |  16 +-
 .../impl/subscriber/SubscriberIdleTest.java        |  56 +++
 .../journal/impl/subscriber/SubscriberTest.java    |   5 +-
 12 files changed, 820 insertions(+), 476 deletions(-)
 create mode 100644 src/main/java/org/apache/sling/distribution/journal/impl/subscriber/BookKeeper.java
 create mode 100644 src/main/java/org/apache/sling/distribution/journal/impl/subscriber/CommandPoller.java
 create mode 100644 src/main/java/org/apache/sling/distribution/journal/impl/subscriber/PackageHandler.java
 create mode 100644 src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberIdle.java
 create mode 100644 src/test/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberIdleTest.java