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 aDistributionSubscriberagent.
-
-
Field Summary
Fields Modifier and Type Field Description static StringFACTORY_PID
-
Constructor Summary
Constructors Constructor Description DistributionPublisher()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidactivate(PublisherConfiguration config, org.osgi.framework.BundleContext context)voiddeactivate()org.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.DistributionQueuegetQueue(String queueName)Iterable<String>getQueueNames()Get queue names for alive subscribed subscriber agents.org.apache.sling.distribution.agent.DistributionAgentStategetState()
-
-
-
Field Detail
-
FACTORY_PID
public static final String FACTORY_PID
- See Also:
- Constant Field Values
-
-
Method Detail
-
activate
public void activate(PublisherConfiguration config, org.osgi.framework.BundleContext context)
-
deactivate
public void deactivate()
-
getQueueNames
@Nonnull public Iterable<String> getQueueNames()
Get queue names for alive subscribed subscriber agents.- Specified by:
getQueueNamesin interfaceorg.apache.sling.distribution.agent.spi.DistributionAgent
-
getQueue
public org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String queueName)
- 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
-
-