public interface ClusterQueueMBean extends QueueMBean, ClusterDestinationMBean
Modifier and Type | Method and Description |
---|---|
String |
getConsumerStatus()
Gets consumer status (NO, NORMAL, HIGH).
|
int |
getConsumThreshold()
Gets the number of pending "receive" requests above which a queue will
request messages from the other queues of the cluster.
|
String |
getProducerStatus()
Gets producer status (NO, NORMAL, HIGH).
|
int |
getProducThreshold()
Gets the number of messages above which a queue is considered loaded.
|
float |
getRateOfFlow()
Gets an evaluation of the flow of messages handled by the queue.
|
int |
getReceivedFromCluster() |
int |
getSentToCluster() |
String |
getStatus()
Gets the status of the queue (RUN, INIT or WAIT).
|
long |
getWaitAfterClusterReq()
Gets the time (in ms) during which a queue which requested something from
the cluster is not authorized to do it again.
|
boolean |
isAutoEvalThreshold()
True if an automatic reevaluation of the queues' thresholds values is
allowed according to their activity.
|
void |
setAutoEvalThreshold(boolean autoEvalThreshold)
Automatic reevaluation of the queues' thresholds can be done according to
their activity.
|
void |
setConsumThreshold(int consumThreshold)
Sets the number of pending "receive" requests above which a queue will
request messages from the other queues of the cluster.
|
void |
setProducThreshold(int producThreshold)
Sets the number of messages above which a queue is considered loaded.
|
void |
setWaitAfterClusterReq(long waitAfterClusterReq)
Sets the time (in ms) during which a queue which requested something from
the cluster is not authorized to do it again.
|
cleanPendingMessage, cleanWaitingRequest, getConsumerLoad, getDeliveredMessageCount, getMessage, getMessages, getMessagesView, getNbMaxMsg, getNbMsgsDeniedSinceCreation, getPendingMessageCount, getProducerLoad, getRedeliveryDelay, getThreshold, getWaitingRequestCount, setNbMaxMsg, setRedeliveryDelay, setThreshold
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod, toString
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
getClusterElements
int getProducThreshold()
void setProducThreshold(int producThreshold)
producThreshold
- the new thresholdint getConsumThreshold()
void setConsumThreshold(int consumThreshold)
consumThreshold
- the new thresholdboolean isAutoEvalThreshold()
void setAutoEvalThreshold(boolean autoEvalThreshold)
autoEvalThreshold
- true to enable auto evaluation of thresholdslong getWaitAfterClusterReq()
void setWaitAfterClusterReq(long waitAfterClusterReq)
waitAfterClusterReq
- the minimum time to wait before another cluster
request.float getRateOfFlow()
String getStatus()
LoadingFactor.Status
String getConsumerStatus()
LoadingFactor.ConsumerStatus
String getProducerStatus()
LoadingFactor.ProducerStatus
int getReceivedFromCluster()
int getSentToCluster()
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.