@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 |
---|---|
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.
|
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 |
isPreferRunOnCreationInstance()
Prefer to run the job on the same instance it was created on.
|
long getRetryDelayInMs()
int getMaxRetries()
QueueConfiguration.Type getType()
QueueConfiguration.ThreadPriority getThreadPriority()
int getMaxParallel()
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()
true
if running on the creation instance is preferred.Copyright © 2017 The Apache Software Foundation. All rights reserved.