Package 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

Modifier and Type	Method	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.

Methods inherited from interface fr.dyade.aaa.agent.AgentMBean

getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling

Methods inherited from interface org.objectweb.joram.mom.dest.ClusterDestinationMBean

getClusterElements

Methods inherited from interface org.objectweb.joram.mom.dest.DestinationMBean

delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getType, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod, toString

Methods inherited from interface org.objectweb.joram.mom.dest.QueueMBean

cleanPendingMessage, cleanWaitingRequest, clear, exportMessages, getConsumerLoad, getDelayedMessage, getDelayedMessageCount, getDelayedMessages, getDeliveredMessageCount, getDeliveryDelay, getMessage, getMessages, getNbMaxMsg, getNbMsgsDeniedSinceCreation, getPendingMessageCount, getProducerLoad, getRedeliveryDelay, getThreshold, getWaitingRequestCount, isPause, setDeliveryDelay, setNbMaxMsg, setPause, setRedeliveryDelay, setThreshold

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

getStatus

String getStatus()

Gets the status of the queue (RUN, INIT or WAIT).

Returns:

the status of the queue

See Also:

LoadingFactor.Status

getConsumerStatus

String getConsumerStatus()

Gets consumer status (NO, NORMAL, HIGH).

Returns:

consumer status

See Also:

LoadingFactor.ConsumerStatus

getProducerStatus

String getProducerStatus()

Gets producer status (NO, NORMAL, HIGH).

Returns:

producer status

See Also:

LoadingFactor.ProducerStatus

getReceivedFromCluster

int getReceivedFromCluster()

getSentToCluster

int getSentToCluster()