Class InternalQueueConfiguration

    • Constructor Detail

      • InternalQueueConfiguration

        public InternalQueueConfiguration()
    • Method Detail

      • isValid

        public boolean isValid()
      • match

        public String match​(String topic)
        Check if the queue processes the event.
        Parameters:
        topic - The topic of the event
        Returns:
        The queue name or null
      • getName

        public String getName()
        Return the name of the queue.
      • getRetryDelayInMs

        public long getRetryDelayInMs()
        Specified by:
        getRetryDelayInMs in interface org.apache.sling.event.jobs.QueueConfiguration
        See Also:
        QueueConfiguration.getRetryDelayInMs()
      • getMaxRetries

        public int getMaxRetries()
        Specified by:
        getMaxRetries in interface org.apache.sling.event.jobs.QueueConfiguration
        See Also:
        QueueConfiguration.getMaxRetries()
      • getType

        public org.apache.sling.event.jobs.QueueConfiguration.Type getType()
        Specified by:
        getType in interface org.apache.sling.event.jobs.QueueConfiguration
        See Also:
        QueueConfiguration.getType()
      • getMaxParallel

        public int getMaxParallel()
        Specified by:
        getMaxParallel in interface org.apache.sling.event.jobs.QueueConfiguration
        See Also:
        QueueConfiguration.getMaxParallel()
      • getTopics

        public String[] getTopics()
        Specified by:
        getTopics in interface org.apache.sling.event.jobs.QueueConfiguration
        See Also:
        QueueConfiguration.getTopics()
      • getRanking

        public int getRanking()
        Specified by:
        getRanking in interface org.apache.sling.event.jobs.QueueConfiguration
        See Also:
        QueueConfiguration.getRanking()
      • getPid

        public String getPid()
      • isKeepJobs

        public boolean isKeepJobs()
        Specified by:
        isKeepJobs in interface org.apache.sling.event.jobs.QueueConfiguration
      • getOwnThreadPoolSize

        public int getOwnThreadPoolSize()
        Specified by:
        getOwnThreadPoolSize in interface org.apache.sling.event.jobs.QueueConfiguration
      • isPreferRunOnCreationInstance

        public boolean isPreferRunOnCreationInstance()
        Specified by:
        isPreferRunOnCreationInstance in interface org.apache.sling.event.jobs.QueueConfiguration
      • getThreadPriority

        public org.apache.sling.event.jobs.QueueConfiguration.ThreadPriority getThreadPriority()
        Specified by:
        getThreadPriority in interface org.apache.sling.event.jobs.QueueConfiguration