This is an automated email from the ASF dual-hosted git repository.
tmaret pushed a change to branch master
in repository
https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git.
from cb89894 SLING-9474 - only seed with processed offsets
add c781465 SLING-9482 - Seed the cache from offset persisted in the
source repository
No new revisions were added by this update.
Summary of changes:
.../journal/impl/publisher/DiscoveryService.java | 27 +-------
.../journal/impl/queue/impl/PubQueueCache.java | 56 ++++++++++++++---
.../impl/queue/impl/PubQueueCacheService.java | 71 +++++++++++++---------
.../impl/queue/impl/QueueCacheCleanupTask.java | 56 +++++++++++++++++
.../impl/QueueCacheSeederTask.java} | 51 ++++++----------
.../journal/impl/subscriber/LocalStore.java | 10 +++
.../impl/publisher/DiscoveryServiceTest.java | 19 +-----
.../journal/impl/queue/impl/PubQueueCacheTest.java | 12 +++-
.../impl/queue/impl/PubQueueProviderTest.java | 11 +++-
9 files changed, 193 insertions(+), 120 deletions(-)
create mode 100644
src/main/java/org/apache/sling/distribution/journal/impl/queue/impl/QueueCacheCleanupTask.java
copy
src/main/java/org/apache/sling/distribution/journal/impl/{publisher/PackageCleanupTask.java
=> queue/impl/QueueCacheSeederTask.java} (56%)
