org.objectweb.joram.mom.dest
Interface ClusterQueueMBean

All Superinterfaces:
AgentMBean, ClusterDestinationMBean, DestinationMBean, QueueMBean
All Known Implementing Classes:
ClusterQueue

public interface ClusterQueueMBean
extends QueueMBean, ClusterDestinationMBean


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

getProducThreshold

int getProducThreshold()
Gets the number of messages above which a queue is considered loaded.

Returns:
the produce threshold

setProducThreshold

void setProducThreshold(int producThreshold)
Sets the number of messages above which a queue is considered loaded.

Parameters:
producThreshold - the new threshold

getConsumThreshold

int getConsumThreshold()
Gets the number of pending "receive" requests above which a queue will request messages from the other queues of the cluster.

Returns:
the consume threshold

setConsumThreshold

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.

Parameters:
consumThreshold - the new threshold

isAutoEvalThreshold

boolean isAutoEvalThreshold()
True if an automatic reevaluation of the queues' thresholds values is allowed according to their activity.

Returns:
true if auto evaluation of thresholds is allowed.

setAutoEvalThreshold

void setAutoEvalThreshold(boolean autoEvalThreshold)
Automatic reevaluation of the queues' thresholds can be done according to their activity.

Parameters:
autoEvalThreshold - true to enable auto evaluation of thresholds

getWaitAfterClusterReq

long getWaitAfterClusterReq()
Gets the time (in ms) during which a queue which requested something from the cluster is not authorized to do it again.

Returns:
the minimum time to wait before another cluster request.

setWaitAfterClusterReq

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.

Parameters:
waitAfterClusterReq - the minimum time to wait before another cluster request.

getRateOfFlow

float getRateOfFlow()
Gets an evaluation of the flow of messages handled by the queue.

Returns:
the rate of flow

isOverloaded

boolean isOverloaded()
Tells if the queue is overloaded.

Returns:
true if the queue is overloaded

getStatus

java.lang.String getStatus()
Gets the status of the queue (RUN, INIT or WAIT).

Returns:
the status of the queue
See Also:
LoadingFactor.Status

getConsumerStatus

java.lang.String getConsumerStatus()
Gets consumer status (NO, NORMAL, HIGH).

Returns:
consumer status
See Also:
LoadingFactor.ConsumerStatus

getProducerStatus

java.lang.String getProducerStatus()
Gets producer status (NO, NORMAL, HIGH).

Returns:
producer status
See Also:
LoadingFactor.ProducerStatus


Copyright © 2011 ScalAgent D.T.. All Rights Reserved.