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 2020/03/27 12:39:27 UTC

[sling-org-apache-sling-distribution-journal] branch SLING-9259 updated (3ff39d5 -> dab2feb)

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

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


    from 3ff39d5  SLING-9259 - Extract service subscriber code into separate package
     add dab2feb  SLING-9259 - Remove SubQueue, add factory for BookKeeper, simplify PreCondition

No new revisions were added by this update.

Summary of changes:
 .../impl/precondition/DefaultPrecondition.java     |   4 +-
 .../journal/impl/precondition/Precondition.java    |   3 +-
 .../impl/precondition/StagingPrecondition.java     |  30 +---
 .../impl/subscriber/DistributionSubscriber.java    | 155 +++++--------------
 .../journal/impl/subscriber/SubQueue.java          | 167 ---------------------
 .../journal/service/subscriber/BookKeeper.java     |  31 ++--
 .../service/subscriber/BookKeeperFactory.java      |  83 ++++++++++
 .../subscriber/ContentPackageExtractor.java        |   2 +-
 .../service/subscriber/ImportedEventFactory.java   |   2 +-
 .../journal/service/subscriber/LocalStore.java     |   2 +-
 .../journal/service/subscriber/PackageHandler.java |  13 +-
 .../journal/service/subscriber/PackageRetries.java |   2 +-
 .../service/subscriber/SubscriberMetrics.java      |   2 -
 .../journal/shared/DistributionMetricsService.java |   2 -
 .../impl/precondition/DefaultPreconditionTest.java |   5 +-
 .../impl/precondition/StagingPreconditionTest.java |  52 ++-----
 .../journal/impl/subscriber/SubscriberTest.java    |  60 +++-----
 .../subscriber/ContentPackageExtractorTest.java    |   1 -
 .../journal/service/subscriber/SubQueueTest.java   |  75 ---------
 19 files changed, 193 insertions(+), 498 deletions(-)
 delete mode 100644 src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubQueue.java
 create mode 100644 src/main/java/org/apache/sling/distribution/journal/service/subscriber/BookKeeperFactory.java
 delete mode 100644 src/test/java/org/apache/sling/distribution/journal/service/subscriber/SubQueueTest.java