@ProviderType
public interface QueueConfiguration
Modifier and Type | Interface and Description |
---|---|
static class |
QueueConfiguration.ThreadPriority
The thread priority.
|
static class |
QueueConfiguration.Type
The queue type.
|
Modifier and Type | Method and Description |
---|---|
String[] |
getApplicationIds()
Deprecated.
This information is not used anymore
|
int |
getMaxParallel()
Return the max number of parallel processes.
|
int |
getMaxRetries()
Return the max number of retries, -1 for endless retry!
|
int |
getOwnThreadPoolSize()
Return the size for the optional thread pool for this queue.
|
JobUtil.JobPriority |
getPriority()
Deprecated.
|
int |
getRanking()
Get the ranking of this configuration.
|
long |
getRetryDelayInMs()
Return the retry delay in ms
|
QueueConfiguration.ThreadPriority |
getThreadPriority()
Return the thread priority for the job thread
|
String[] |
getTopics()
The list of topics this queue is bound to.
|
QueueConfiguration.Type |
getType()
Return the queue type.
|
boolean |
isKeepJobs()
Whether successful jobs are kept for a complete history
|
boolean |
isLocalQueue()
Deprecated.
This information is not used anymore
|
boolean |
isPreferRunOnCreationInstance()
Prefer to run the job on the same instance it was created on.
|
long getRetryDelayInMs()
int getMaxRetries()
QueueConfiguration.Type getType()
@Deprecated JobUtil.JobPriority getPriority()
getThreadPriority()
QueueConfiguration.ThreadPriority getThreadPriority()
int getMaxParallel()
@Deprecated boolean isLocalQueue()
@Deprecated String[] getApplicationIds()
String[] getTopics()
boolean isKeepJobs()
true
if successful jobs are kept.int getOwnThreadPoolSize()
0
if the default thread pool
should be used.int getRanking()
boolean isPreferRunOnCreationInstance()
Copyright © 2015 The Apache Software Foundation. All rights reserved.