Class JobConsumerManager


  • public class JobConsumerManager
    extends Object
    This component manages/keeps track of all job consumer services.
    • Constructor Detail

      • JobConsumerManager

        public JobConsumerManager()
    • Method Detail

      • deactivate

        protected void deactivate()
      • getExecutor

        public org.apache.sling.event.jobs.consumer.JobExecutor getExecutor​(String topic)
        Get the executor for the topic.
        Parameters:
        topic - The job topic
        Returns:
        A consumer or null
      • registerListener

        public void registerListener​(String key,
                                     org.apache.sling.event.jobs.consumer.JobExecutor consumer,
                                     org.apache.sling.event.jobs.consumer.JobExecutionContext handler)
      • unregisterListener

        public void unregisterListener​(String key)
      • getTopics

        public String getTopics()
        Return the topics information of this instance.
      • bindJobConsumer

        protected void bindJobConsumer​(org.osgi.framework.ServiceReference<org.apache.sling.event.jobs.consumer.JobConsumer> serviceReference)
        Bind a new consumer
        Parameters:
        serviceReference - The service reference to the consumer.
      • unbindJobConsumer

        protected void unbindJobConsumer​(org.osgi.framework.ServiceReference<org.apache.sling.event.jobs.consumer.JobConsumer> serviceReference)
        Unbind a consumer
        Parameters:
        serviceReference - The service reference to the consumer.
      • bindJobExecutor

        protected void bindJobExecutor​(org.osgi.framework.ServiceReference<org.apache.sling.event.jobs.consumer.JobExecutor> serviceReference)
        Bind a new executor
        Parameters:
        serviceReference - The service reference to the executor.
      • unbindJobExecutor

        protected void unbindJobExecutor​(org.osgi.framework.ServiceReference<org.apache.sling.event.jobs.consumer.JobExecutor> serviceReference)
        Unbind a executor
        Parameters:
        serviceReference - The service reference to the executor.