public class JobQueueStat extends Object
Constructor and Description |
---|
JobQueueStat(String queueName,
org.codehaus.jackson.JsonNode jobJson)
Constructor from a
JsonNode object
Format : |
JobQueueStat(String queueName,
long startTime,
long lastActivated,
long lastFinished,
int queuedJobs,
int activeJobs,
int finishedJobs,
int failedJobs,
int cancelledJobs,
int avgProcessingTime,
int avgWaitingTime,
String type,
List<String> topics,
int maxParallel,
int maxRetries,
int retryDelay,
String priority,
String statusInfo) |
Modifier and Type | Method and Description |
---|---|
int |
getActiveJobs() |
int |
getAvgProcessingTime() |
int |
getAvgWaitingTime() |
int |
getCancelledJobs() |
int |
getFailedJobs() |
int |
getFinishedJobs() |
long |
getLastActivated() |
long |
getLastFinished() |
int |
getMaxParallel() |
int |
getMaxRetries() |
String |
getPriority() |
int |
getQueuedJobs() |
String |
getQueueName() |
int |
getRetryDelay() |
long |
getStartTime() |
String |
getStatusInfo() |
List<String> |
getTopics() |
String |
getType() |
public JobQueueStat(String queueName, long startTime, long lastActivated, long lastFinished, int queuedJobs, int activeJobs, int finishedJobs, int failedJobs, int cancelledJobs, int avgProcessingTime, int avgWaitingTime, String type, List<String> topics, int maxParallel, int maxRetries, int retryDelay, String priority, String statusInfo)
public JobQueueStat(String queueName, org.codehaus.jackson.JsonNode jobJson)
JsonNode
object
Format :
{
statistics: {
start_time: 1375793518694,
last_activated: 1375793524795,
last_finished: -1,
queued_jobs: 1,
active_jobs: 0,
finished_jobs: 0,
failed_jobs: 4,
cancelled_jobs: 0,
avg_processing_time: 0,
avg_waiting_time: 1522
},
configuration: {
type: "TOPIC_ROUND_ROBIN",
topics: [ "/my/topic/one/*", ""/my/topic/two/*" ],
max_parallel: 8,
max_retries: 10,
retry_delay: 2000,
priority: "MIN"
},
status_info: "isWaiting=false, suspendedSince=-1, isWaitingForNext=true, asyncJobs=0, jobCount=0, eventCount=0"
}
queueName
- the name of the job queuejobJson
- the json node to parsepublic String getQueueName()
public long getStartTime()
public long getLastActivated()
public long getLastFinished()
public int getQueuedJobs()
public int getActiveJobs()
public int getFinishedJobs()
public int getFailedJobs()
public int getCancelledJobs()
public int getAvgProcessingTime()
public int getAvgWaitingTime()
public String getType()
public int getMaxParallel()
public int getMaxRetries()
public int getRetryDelay()
public String getPriority()
public String getStatusInfo()
Copyright © 2018. All rights reserved.