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