Class DistributionPublisher
java.lang.Object
org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- All Implemented Interfaces:
org.apache.sling.distribution.agent.spi.DistributionAgent
@ParametersAreNonnullByDefault
public class DistributionPublisher
extends Object
implements org.apache.sling.distribution.agent.spi.DistributionAgent
A Publisher SCD agent which produces messages to be consumed by a
DistributionSubscriber agent.-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionDistributionPublisher(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, org.apache.sling.distribution.packaging.DistributionPackageBuilder packageBuilder, DiscoveryService discoveryService, PackageMessageFactory factory, org.osgi.service.event.EventAdmin eventAdmin, org.apache.sling.commons.metrics.MetricsService metricsService, PubQueueProvider pubQueueProvider, org.osgi.service.condition.Condition limitToggle, PublisherConfiguration config, org.osgi.framework.BundleContext context) -
Method Summary
Modifier and TypeMethodDescriptionvoidorg.apache.sling.distribution.DistributionResponseexecute(org.apache.sling.api.resource.ResourceResolver resourceResolver, org.apache.sling.distribution.DistributionRequest request) org.apache.sling.distribution.log.spi.DistributionLoggetLog()org.apache.sling.distribution.queue.spi.DistributionQueueGet queue names for alive subscribed subscriber agents.org.apache.sling.distribution.agent.DistributionAgentStategetState()
-
Field Details
-
FACTORY_PID
- See Also:
-
-
Constructor Details
-
DistributionPublisher
public DistributionPublisher(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, org.apache.sling.distribution.packaging.DistributionPackageBuilder packageBuilder, DiscoveryService discoveryService, PackageMessageFactory factory, org.osgi.service.event.EventAdmin eventAdmin, org.apache.sling.commons.metrics.MetricsService metricsService, PubQueueProvider pubQueueProvider, org.osgi.service.condition.Condition limitToggle, PublisherConfiguration config, org.osgi.framework.BundleContext context)
-
-
Method Details
-
deactivate
public void deactivate() -
getQueueNames
Get queue names for alive subscribed subscriber agents.- Specified by:
getQueueNamesin interfaceorg.apache.sling.distribution.agent.spi.DistributionAgent
-
getQueue
- Specified by:
getQueuein interfaceorg.apache.sling.distribution.agent.spi.DistributionAgent
-
getLog
@Nonnull public org.apache.sling.distribution.log.spi.DistributionLog getLog()- Specified by:
getLogin interfaceorg.apache.sling.distribution.agent.spi.DistributionAgent
-
getState
@Nonnull public org.apache.sling.distribution.agent.DistributionAgentState getState()- Specified by:
getStatein interfaceorg.apache.sling.distribution.agent.spi.DistributionAgent
-
execute
@Nonnull public org.apache.sling.distribution.DistributionResponse execute(org.apache.sling.api.resource.ResourceResolver resourceResolver, org.apache.sling.distribution.DistributionRequest request) throws org.apache.sling.distribution.common.DistributionException - Specified by:
executein interfaceorg.apache.sling.distribution.agent.spi.DistributionAgent- Throws:
org.apache.sling.distribution.common.DistributionException
-