commit	26c217ce80b0f2c29a0132ccbaf48077bdaa6e0c	[log] [tgz]
author	tmaret <tmaret@adobe.com>	Thu Feb 01 18:01:58 2018 +0100
committer	tmaret <tmaret@adobe.com>	Fri Feb 02 11:20:49 2018 +0100
tree	02f352bff1c04aa6595ef668cbdde46a737cdd94
parent	d50eac320d7aaabad14c76f754a54de85b2a415d [diff]

SLING-7168 - Allow to implement custom distribution queue

* Export the org.apache.sling.distribution.queue package
* Export the org.apache.sling.distribution.queue.spi package
* Export the org.apache.sling.distribution.log.spi package
* Expose DistributionQueue and DistributionLog as a consumer types
* Hide DistributionQueueProcessor and DistributionQueueProvider
* Make the exposed classes final
* Minor typo cleanups

pom.xml[diff]
src/main/java/org/apache/sling/distribution/agent/DistributionAgent.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/ForwardDistributionAgentFactory.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/QueueDistributionAgentFactory.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/QueueingDistributionPackageProcessor.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/ReverseDistributionAgentFactory.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/SimpleDistributionAgent.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/SimpleDistributionAgentFactory.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/SimpleDistributionAgentQueueProcessor.java[diff]
src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java[diff]
src/main/java/org/apache/sling/distribution/component/impl/DefaultDistributionComponentProvider.java[diff]
src/main/java/org/apache/sling/distribution/component/impl/DistributionComponentKind.java[diff]
src/main/java/org/apache/sling/distribution/log/impl/DefaultDistributionLog.java[diff]
src/main/java/org/apache/sling/distribution/log/spi/DistributionLog.java[Renamed from src/main/java/org/apache/sling/distribution/log/DistributionLog.java - diff]
src/main/java/org/apache/sling/distribution/log/spi/package-info.java[Copied from src/main/java/org/apache/sling/distribution/log/DistributionLog.java - diff]
src/main/java/org/apache/sling/distribution/monitor/DistributionQueueHealthCheck.java[diff]
src/main/java/org/apache/sling/distribution/monitor/impl/DistributionQueueMBeanImpl.java[diff]
src/main/java/org/apache/sling/distribution/monitor/impl/MonitoringDistributionQueueProvider.java[diff]
src/main/java/org/apache/sling/distribution/packaging/DistributionPackageExporter.java[diff]
src/main/java/org/apache/sling/distribution/packaging/impl/exporter/AgentDistributionPackageExporter.java[diff]
src/main/java/org/apache/sling/distribution/queue/DistributionQueueEntry.java[diff]
src/main/java/org/apache/sling/distribution/queue/DistributionQueueItem.java[diff]
src/main/java/org/apache/sling/distribution/queue/DistributionQueueItemStatus.java[diff]
src/main/java/org/apache/sling/distribution/queue/DistributionQueueStatus.java[diff]
src/main/java/org/apache/sling/distribution/queue/DistributionQueueType.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/AsyncDeliveryDispatchingStrategy.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/CachingDistributionQueue.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/DistributionQueueDispatchingStrategy.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/DistributionQueueProcessor.java[Renamed from src/main/java/org/apache/sling/distribution/queue/DistributionQueueProcessor.java - diff]
src/main/java/org/apache/sling/distribution/queue/impl/DistributionQueueProvider.java[Renamed from src/main/java/org/apache/sling/distribution/queue/DistributionQueueProvider.java - diff]
src/main/java/org/apache/sling/distribution/queue/impl/DistributionQueueWrapper.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/ErrorQueueDispatchingStrategy.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/MultipleQueueDispatchingStrategy.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/PriorityQueueDispatchingStrategy.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/SimpleAgentDistributionQueue.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/jobhandling/DistributionAgentJobConsumer.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/jobhandling/JobHandlingDistributionQueue.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/jobhandling/JobHandlingDistributionQueueProvider.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueue.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueCheckpoint.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueProcessor.java[diff]
src/main/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueProvider.java[diff]
src/main/java/org/apache/sling/distribution/queue/package-info.java[diff]
src/main/java/org/apache/sling/distribution/queue/spi/DistributionQueue.java[Renamed from src/main/java/org/apache/sling/distribution/queue/DistributionQueue.java - diff]
src/main/java/org/apache/sling/distribution/queue/spi/package-info.java[Copied from src/main/java/org/apache/sling/distribution/log/DistributionLog.java - diff]
src/main/java/org/apache/sling/distribution/resources/impl/ExtendedDistributionServiceResourceProvider.java[diff]
src/main/java/org/apache/sling/distribution/servlet/DistributionAgentLogServlet.java[diff]
src/main/java/org/apache/sling/distribution/servlet/DistributionAgentQueueServlet.java[diff]
src/test/java/org/apache/sling/distribution/agent/impl/QueueingDistributionPackageProcessorTest.java[diff]
src/test/java/org/apache/sling/distribution/agent/impl/SimpleDistributionAgentQueueProcessorTest.java[diff]
src/test/java/org/apache/sling/distribution/agent/impl/SimpleDistributionAgentTest.java[diff]
src/test/java/org/apache/sling/distribution/monitor/DistributionQueueHealthCheckTest.java[diff]
src/test/java/org/apache/sling/distribution/monitor/impl/DistributionQueueMBeanTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/AsyncDeliveryDispatchingStrategyTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/PriorityQueueDispatchingStrategyTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/SingleQueueDistributionStrategyTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/jobhandling/DistributionAgentJobConsumerTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/jobhandling/JobHandlingDistributionQueueProviderTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/jobhandling/JobHandlingDistributionQueueTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueCheckpointTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueProcessorTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueProviderTest.java[diff]
src/test/java/org/apache/sling/distribution/queue/impl/simple/SimpleDistributionQueueTest.java[diff]

63 files changed

tree: 02f352bff1c04aa6595ef668cbdde46a737cdd94

src/
.gitignore
LICENSE
pom.xml
README.md

README.md

Apache Sling Distribution Core

This module is part of the Apache Sling project.