|
||||||||||
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")}),@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="queue.runlocal",boolValue=false),@Property(name="queue.applicationids",unbounded=ARRAY)}) public class InternalQueueConfiguration
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.sling.event.jobs.QueueConfiguration |
---|
QueueConfiguration.Type |
Constructor Summary | |
---|---|
InternalQueueConfiguration()
|
|
InternalQueueConfiguration(org.osgi.service.event.Event jobEvent)
|
Method Summary | |
---|---|
protected void |
activate(Map<String,Object> params)
Create a new queue configuration |
static InternalQueueConfiguration |
fromConfiguration(Map<String,Object> params)
Create a new configuration from a config |
String[] |
getApplicationIds()
Application ids - returns an array of application ids if this queue is bound to some cluster nodes. |
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()
Is this a local running queue (= processing only jobs started on the same instance.) |
boolean |
isSkipped(JobEvent event)
Checks if the event should be skipped. |
boolean |
isValid()
|
boolean |
match(JobEvent event)
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()
public InternalQueueConfiguration(org.osgi.service.event.Event jobEvent)
Method Detail |
---|
public static InternalQueueConfiguration fromConfiguration(Map<String,Object> params)
@Activate protected void activate(Map<String,Object> params)
public boolean isValid()
public boolean match(JobEvent event)
event
- The eventpublic String getName()
public boolean isSkipped(JobEvent event)
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()
public boolean isLocalQueue()
QueueConfiguration
isLocalQueue
in interface QueueConfiguration
QueueConfiguration.isLocalQueue()
public String[] getApplicationIds()
QueueConfiguration
getApplicationIds
in interface QueueConfiguration
QueueConfiguration.getApplicationIds()
public String[] getTopics()
QueueConfiguration
getTopics
in interface QueueConfiguration
QueueConfiguration.getTopics()
public int getRanking()
QueueConfiguration
getRanking
in interface QueueConfiguration
QueueConfiguration.getRanking()
public String getPid()
public String toString()
toString
in class Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |