|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ClusterQueueMBean
Method Summary | |
---|---|
java.lang.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. |
java.lang.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. |
java.lang.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. |
boolean |
isOverloaded()
Tells if the queue is overloaded. |
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. |
Methods inherited from interface org.objectweb.joram.mom.dest.QueueMBean |
---|
cleanPendingMessage, cleanWaitingRequest, getDeliveredMessageCount, getMessage, getMessages, getMessagesView, getNbMaxMsg, getPendingMessageCount, getThreshold, getWaitingRequestCount, setNbMaxMsg, setThreshold |
Methods inherited from interface org.objectweb.joram.mom.dest.DestinationMBean |
---|
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod, toString |
Methods inherited from interface fr.dyade.aaa.agent.AgentMBean |
---|
getAgentId, getCommitTime, getReactNb, getReactTime, isFixed |
Methods inherited from interface org.objectweb.joram.mom.dest.ClusterDestinationMBean |
---|
getClusterElements |
Method Detail |
---|
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()
boolean isOverloaded()
java.lang.String getStatus()
LoadingFactor.Status
java.lang.String getConsumerStatus()
LoadingFactor.ConsumerStatus
java.lang.String getProducerStatus()
LoadingFactor.ProducerStatus
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |