|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sling.event.impl.jobs.config.InternalQueueConfiguration
@Service(value=InternalQueueConfiguration.class) @Properties(value={@Property(name="queue.name"),@Property(name="queue.type",value="UNORDERED",options={@PropertyOption(name="UNORDERED",value="Parallel"),@PropertyOption(name="ORDERED",value="Ordered"),@PropertyOption(name="TOPIC_ROUND_ROBIN",value="Topic Round Robin"),@PropertyOption(name="IGNORE",value="Ignore"),@PropertyOption(name="DROP",value="Drop")}),@Property(name="queue.topics",unbounded=ARRAY),@Property(name="queue.maxparallel",intValue=15),@Property(name="queue.retries",intValue=10),@Property(name="queue.retrydelay",longValue=2000L),@Property(name="queue.priority",value="NORM",options={@PropertyOption(name="NORM",value="Norm"),@PropertyOption(name="MIN",value="Min"),@PropertyOption(name="MAX",value="Max")}),@Property(name="service.ranking",intValue=0,propertyPrivate=false,label="%queue.ranking.name",description="%queue.ranking.description")}) public class InternalQueueConfiguration
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.sling.event.jobs.QueueConfiguration |
---|
QueueConfiguration.Type |
Constructor Summary | |
---|---|
InternalQueueConfiguration()
|
Method Summary | |
---|---|
protected void |
activate(Map<String,Object> params)
Create a new queue configuration |
int |
compareTo(InternalQueueConfiguration other)
|
static InternalQueueConfiguration |
fromConfiguration(Map<String,Object> params)
Create a new configuration from a config |
String[] |
getApplicationIds()
Deprecated. |
int |
getMaxParallel()
Return the max number of parallel processes. |
int |
getMaxRetries()
Return the max number of retries, -1 for endless retry! |
String |
getName()
Return the name of the queue. |
String |
getPid()
|
JobUtil.JobPriority |
getPriority()
Return the thread priority for the job thread. |
int |
getRanking()
Get the ranking of this configuration. |
long |
getRetryDelayInMs()
Return the retry delay in ms |
String[] |
getTopics()
The list of topics this queue is bound to. |
QueueConfiguration.Type |
getType()
Return the queue type. |
boolean |
isLocalQueue()
Deprecated. |
boolean |
isValid()
|
String |
match(String topic)
Check if the queue processes the event. |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public InternalQueueConfiguration()
Method Detail |
---|
public static InternalQueueConfiguration fromConfiguration(Map<String,Object> params)
@Activate protected void activate(Map<String,Object> params)
public boolean isValid()
public String match(String topic)
topic
- The topic of the event
null
public String getName()
public long getRetryDelayInMs()
QueueConfiguration
getRetryDelayInMs
in interface QueueConfiguration
QueueConfiguration.getRetryDelayInMs()
public int getMaxRetries()
QueueConfiguration
getMaxRetries
in interface QueueConfiguration
QueueConfiguration.getMaxRetries()
public QueueConfiguration.Type getType()
QueueConfiguration
getType
in interface QueueConfiguration
QueueConfiguration.getType()
public JobUtil.JobPriority getPriority()
QueueConfiguration
getPriority
in interface QueueConfiguration
QueueConfiguration.getPriority()
public int getMaxParallel()
QueueConfiguration
getMaxParallel
in interface QueueConfiguration
QueueConfiguration.getMaxParallel()
@Deprecated public boolean isLocalQueue()
isLocalQueue
in interface QueueConfiguration
public String[] getTopics()
QueueConfiguration
getTopics
in interface QueueConfiguration
QueueConfiguration.getTopics()
public int getRanking()
QueueConfiguration
getRanking
in interface QueueConfiguration
QueueConfiguration.getRanking()
public String getPid()
@Deprecated public String[] getApplicationIds()
getApplicationIds
in interface QueueConfiguration
public String toString()
toString
in class Object
public int compareTo(InternalQueueConfiguration other)
compareTo
in interface Comparable<InternalQueueConfiguration>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |