Class QueueManager

    • Constructor Detail

      • QueueManager

        public QueueManager()
    • Method Detail

      • activate

        protected void activate​(Map<String,​Object> props)
        Activate this component.
        Parameters:
        props - Configuration properties
      • deactivate

        protected void deactivate()
        Deactivate this component.
      • run

        public void run()
        This method is invoked periodically by the scheduler. In the default configuration every minute
        Specified by:
        run in interface Runnable
        See Also:
        Runnable.run()
      • getQueue

        public org.apache.sling.event.jobs.Queue getQueue​(String name)
        Parameters:
        name - The queue name
        Returns:
        The queue or null.
        See Also:
        JobManager.getQueue(java.lang.String)
      • getQueues

        public Iterable<org.apache.sling.event.jobs.Queue> getQueues()
        Returns:
        An iterator for the available queues.
        See Also:
        JobManager.getQueues()
      • configurationChanged

        public void configurationChanged​(boolean active)
        This method is called whenever the topology or queue configurations change.
        Specified by:
        configurationChanged in interface ConfigurationChangeListener
        Parameters:
        active - Whether the job handling is active atm.
      • handleEvent

        public void handleEvent​(org.osgi.service.event.Event event)
        Specified by:
        handleEvent in interface org.osgi.service.event.EventHandler
        See Also:
        EventHandler.handleEvent(org.osgi.service.event.Event)
      • bindThreadPool

        protected void bindThreadPool​(org.apache.sling.event.impl.EventingThreadPool etp)
      • unbindThreadPool

        protected void unbindThreadPool​(org.apache.sling.event.impl.EventingThreadPool etp)