This is an automated email from the ASF dual-hosted git repository.
cziegeler pushed a change to branch master
in repository
https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal.git
from 3962278 SLING-13147 - Fix queue name
add 0c2142d build: upgrade sling-bundle-parent to v66 and modernize OSGi
dependencies
new cb677ec Merge pull request #189 from
apache/maia/workflow-1779973181399
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pom.xml | 91 ++++++----
.../journal/bookkeeper/AppliedEvent.java | 15 +-
.../journal/bookkeeper/BookKeeper.java | 177 ++++++++++++-------
.../journal/bookkeeper/BookKeeperConfig.java | 45 ++---
.../journal/bookkeeper/BookKeeperFactory.java | 10 +-
.../bookkeeper/ContentPackageExtractor.java | 31 ++--
.../journal/bookkeeper/CurrentImportInfo.java | 46 ++---
.../journal/bookkeeper/ErrorListener.java | 10 +-
.../journal/bookkeeper/LocalStore.java | 37 ++--
.../journal/bookkeeper/LocalStoreJMX.java | 29 ++--
.../journal/bookkeeper/PackageHandler.java | 25 ++-
.../journal/bookkeeper/PackageHandling.java | 4 +-
.../journal/bookkeeper/PackageRetries.java | 8 +-
.../journal/bookkeeper/SubscriberMetrics.java | 99 ++++++-----
.../journal/impl/discovery/DiscoveryService.java | 48 +++---
.../distribution/journal/impl/discovery/State.java | 29 ++--
.../impl/discovery/TopologyChangeHandler.java | 3 +-
.../journal/impl/discovery/TopologyView.java | 32 ++--
.../journal/impl/discovery/TopologyViewDiff.java | 16 +-
.../impl/discovery/TopologyViewManager.java | 12 +-
.../journal/impl/event/DistributionEvent.java | 40 +++--
.../impl/event/DistributionFailureEvent.java | 14 +-
.../impl/precondition/DefaultPrecondition.java | 5 +-
.../impl/precondition/PackageStatusWatcher.java | 17 +-
.../journal/impl/precondition/Precondition.java | 6 +-
.../impl/precondition/StagingPrecondition.java | 17 +-
.../journal/impl/publisher/AgentState.java | 13 +-
.../publisher/DistributedEventNotifierManager.java | 49 +++---
.../impl/publisher/DistributionPublisher.java | 121 ++++++-------
.../impl/publisher/MessagingCacheCallback.java | 29 ++--
.../impl/publisher/PackageDistributedNotifier.java | 79 +++++----
.../publisher/PackageFactoryConfiguration.java | 9 +-
.../impl/publisher/PackageMessageFactory.java | 58 ++++---
.../impl/publisher/PackageQueuedNotifier.java | 3 +-
.../impl/publisher/PubQueueProviderPublisher.java | 13 +-
.../journal/impl/publisher/PublishMetrics.java | 10 +-
.../impl/publisher/PublisherConfiguration.java | 19 ++-
.../journal/impl/publisher/QueueCacheSeeder.java | 10 +-
.../journal/impl/publisher/RangePoller.java | 36 ++--
.../impl/publisher/SimpleDistributionResponse.java | 6 +-
.../journal/impl/subscriber/Announcer.java | 28 +--
.../journal/impl/subscriber/CommandPoller.java | 39 +++--
.../impl/subscriber/DistributionSubscriber.java | 181 ++++++++++++--------
.../journal/impl/subscriber/IdleCheck.java | 9 +-
.../subscriber/PreConditionTimeoutException.java | 1 -
.../impl/subscriber/SubscriberConfiguration.java | 51 ++++--
.../impl/subscriber/SubscriberIdleCheck.java | 4 +-
.../journal/impl/subscriber/SubscriberReady.java | 47 +++--
.../impl/subscriber/SubscriberReadyStore.java | 2 +-
.../distribution/journal/metrics/DefaultTag.java | 15 +-
.../sling/distribution/journal/metrics/Tag.java | 1 -
.../journal/metrics/TaggedMetrics.java | 7 +-
.../distribution/journal/queue/CacheCallback.java | 4 +
.../distribution/journal/queue/ClearCallback.java | 1 -
.../journal/queue/PubQueueProvider.java | 9 +-
.../journal/queue/PubQueueProviderFactory.java | 3 +-
.../journal/queue/QueueItemFactory.java | 55 +++---
.../distribution/journal/queue/QueueState.java | 8 +-
.../distribution/journal/queue/QueuedCallback.java | 1 -
.../distribution/journal/queue/impl/EntryUtil.java | 8 +-
.../journal/queue/impl/OffsetQueueImpl.java | 17 +-
.../journal/queue/impl/OffsetQueueImplMBean.java | 2 +
.../journal/queue/impl/PubErrQueue.java | 9 +-
.../distribution/journal/queue/impl/PubQueue.java | 63 ++++---
.../journal/queue/impl/PubQueueCache.java | 49 +++---
.../queue/impl/PubQueueProviderFactoryImpl.java | 1 -
.../journal/queue/impl/PubQueueProviderImpl.java | 78 +++++----
.../journal/queue/impl/QueueEntryFactory.java | 17 +-
.../journal/queue/impl/QueueErrors.java | 10 +-
.../distribution/journal/queue/package-info.java | 1 -
.../sling/distribution/journal/shared/AgentId.java | 5 +-
.../journal/shared/DefaultDistributionLog.java | 11 +-
.../sling/distribution/journal/shared/Delay.java | 3 +-
.../shared/DistributionLogEventListener.java | 17 +-
.../journal/shared/DistributionThreadPool.java | 5 +-
.../journal/shared/ExponentialBackOff.java | 12 +-
.../journal/shared/JMXRegistration.java | 13 +-
.../journal/shared/JournalDistributionPackage.java | 12 +-
.../shared/JournalDistributionPackageBuilder.java | 133 ++++++++-------
.../journal/shared/NoOpImportPostProcessor.java | 10 +-
.../journal/shared/NoOpImportPreProcessor.java | 8 +-
.../journal/shared/NoOpInvalidationProcessor.java | 14 +-
.../distribution/journal/shared/OnlyOnLeader.java | 4 +-
.../shared/PublisherConfigurationAvailable.java | 7 +-
.../sling/distribution/journal/shared/Strings.java | 1 -
.../sling/distribution/journal/shared/Timed.java | 7 +-
.../sling/distribution/journal/shared/Topics.java | 6 +-
.../journal/bookkeeper/BookKeeperConfigTest.java | 28 ++-
.../journal/bookkeeper/BookKeeperTest.java | 155 +++++++++--------
.../bookkeeper/ContentPackageExtractorTest.java | 74 ++++----
.../journal/bookkeeper/ErrorListenerTest.java | 18 +-
.../journal/bookkeeper/LocalStoreJMXTest.java | 26 +--
.../journal/bookkeeper/LocalStoreTest.java | 10 +-
.../journal/bookkeeper/PackageRetriesTest.java | 6 +-
.../impl/discovery/DiscoveryServiceTest.java | 72 ++++----
.../journal/impl/discovery/StateTest.java | 46 +++--
.../impl/discovery/TopologyViewDiffTest.java | 49 +++---
.../impl/discovery/TopologyViewManagerTest.java | 29 ++--
.../journal/impl/discovery/TopologyViewTest.java | 89 +++++-----
.../impl/precondition/DefaultPreconditionTest.java | 6 +-
.../precondition/PackageStatusWatcherTest.java | 41 +++--
.../impl/precondition/StagingPreconditionTest.java | 28 ++-
.../DistributedEventNotifierManagerTest.java | 16 +-
.../publisher/DistributionPackageFactoryTest.java | 40 +++--
.../impl/publisher/DistributionPublisherTest.java | 189 ++++++++++++---------
.../impl/publisher/MessagingCacheCallbackTest.java | 64 ++++---
.../publisher/PackageDistributedNotifierTest.java | 34 ++--
.../impl/publisher/PackageMessageFactoryTest.java | 23 +--
.../impl/publisher/PackageQueuedNotifierTest.java | 24 +--
.../impl/publisher/QueueCacheSeederTest.java | 13 +-
.../journal/impl/publisher/RangePollerTest.java | 38 +++--
.../publisher/SimpleDistributionResponseTest.java | 23 +--
.../journal/impl/subscriber/AnnouncerTest.java | 22 ++-
.../journal/impl/subscriber/CommandPollerTest.java | 49 +++---
.../journal/impl/subscriber/EscapeTest.java | 6 +-
.../impl/subscriber/SubscriberIdleCheckTest.java | 16 +-
.../impl/subscriber/SubscriberReadyTest.java | 45 ++---
.../journal/impl/subscriber/SubscriberTest.java | 179 ++++++++++---------
.../journal/metrics/TaggedMetricsTest.java | 6 +-
.../distribution/journal/msg/InMemoryProvider.java | 14 +-
.../distribution/journal/msg/InMemorySender.java | 1 -
.../distribution/journal/msg/InMemoryTopic.java | 6 +-
.../journal/queue/QueueItemFactoryTest.java | 78 ++++-----
.../journal/queue/impl/EntryUtilTest.java | 21 +--
.../journal/queue/impl/OffsetQueueImplJMXTest.java | 17 +-
.../journal/queue/impl/OffsetQueueImplTest.java | 21 ++-
.../journal/queue/impl/PubQueueCacheTest.java | 50 +++---
.../journal/queue/impl/PubQueueProviderTest.java | 149 ++++++++--------
.../journal/queue/impl/PubQueueTest.java | 80 ++++-----
.../journal/queue/impl/QueueErrorsTest.java | 8 +-
.../distribution/journal/shared/AgentIdTest.java | 11 +-
.../journal/shared/DefaultDistributionLogTest.java | 10 +-
.../distribution/journal/shared/DelayTest.java | 6 +-
.../shared/DistributionLogEventListenerTest.java | 36 ++--
.../journal/shared/ExponentialBackoffTest.java | 26 +--
.../JournalDistributionPackageBuilderTest.java | 15 +-
.../shared/JournalDistributionPackageTest.java | 10 +-
.../journal/shared/OnlyOnLeaderTest.java | 4 +-
.../PublisherConfigurationAvailableTest.java | 35 ++--
.../distribution/journal/shared/StringsTest.java | 2 +-
.../journal/shared/SubscriberMetricsTest.java | 8 +-
141 files changed, 2305 insertions(+), 2077 deletions(-)
