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/07/16 10:06:57 UTC

[sling-org-apache-sling-distribution-journal] branch SLING-9583 updated (d7d0452 -> c2f67b5)

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

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


    from d7d0452  SLING-9583 - Sonar
     add 0bbd5ac  SLING-9583 - Remove QueueId
     add 5e72f10  SLING-9583 - Move all queue logic to PubQueueProvider
     add c2f67b5  SLING-9583 - Publish single PubQueueProvider service for compatibility

No new revisions were added by this update.

Summary of changes:
 pom.xml                                            |  2 +-
 .../impl/publisher/DistributionPublisher.java      | 87 ++-------------------
 .../impl/publisher/MessagingCacheCallback.java     | 54 ++++++++++++-
 .../impl/publisher/PubQueueProviderPublisher.java  | 88 ++++++++++++++++++++++
 .../journal/impl/queue/CacheCallback.java          |  4 +
 .../journal/impl/queue/PubQueueProvider.java       | 12 +--
 .../impl/queue/{QueueId.java => QueueState.java}   | 43 +++++------
 .../impl/queue/impl/PubQueueProviderImpl.java      | 69 ++++++++++++-----
 .../{bookkeeper => impl/queue}/package-info.java   |  2 +-
 .../impl/publisher/DistributionPublisherTest.java  | 56 +++++---------
 .../impl/publisher/MessagingCacheCallbackTest.java | 65 +++++++++++++++-
 .../publisher/PubQueueProviderPublisherTest.java   | 75 ++++++++++++++++++
 .../impl/queue/impl/PubQueueProviderTest.java      | 32 ++++----
 13 files changed, 407 insertions(+), 182 deletions(-)
 create mode 100644 src/main/java/org/apache/sling/distribution/journal/impl/publisher/PubQueueProviderPublisher.java
 rename src/main/java/org/apache/sling/distribution/journal/impl/queue/{QueueId.java => QueueState.java} (52%)
 copy src/main/java/org/apache/sling/distribution/journal/{bookkeeper => impl/queue}/package-info.java (93%)
 create mode 100644 src/test/java/org/apache/sling/distribution/journal/impl/publisher/PubQueueProviderPublisherTest.java