Package org.objectweb.joram.mom.dest

Interface AcquisitionQueueMBean

All Superinterfaces:

AcquisitionMBean, AgentMBean, DestinationMBean, QueueMBean

All Known Implementing Classes:

AcquisitionQueue

public interface AcquisitionQueueMBean
extends QueueMBean, AcquisitionMBean

JMX interface for the monitoring queue.

Method Summary

Modifier and Type	Method	Description
String	dumpProperties()
long	getAcquiredMsgCount()	Returns the number of messages acquired by the acquisition handler.
long	getDiffMax()	Returns the maximum number of acquired messages waiting to be handled by the destination.
long	getDiffMin()	Returns the minimum threshold of acquired messages waiting to be handled by the destination for restarting the acquisition handler.
long	getHandledMsgCount()	Returns the number of acquired messages processed by the destination.
long	getPendingMax()	Returns the maximum number of waiting messages in the destination.
long	getPendingMin()	Returns the minimum threshold of waiting messages in the destination for restarting the acquisition handler.
boolean	isHandlerRunning()	Returns the acquisition handler status.
void	start()	Starts the handler.
void	stop()	Stops the handler.

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

getAcquisitionClassName, getAcquisitionPeriod, getExpiration, getPriority, isMessagePersistent, setExpiration, setMessagePersistent, setPriority

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.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

getAcquiredMsgCount

long getAcquiredMsgCount()

Returns the number of messages acquired by the acquisition handler. Be careful this counter is reseted at each time the server starts.

Returns:

the number of messages acquired by the acquisition handler.

getHandledMsgCount

long getHandledMsgCount()

Returns the number of acquired messages processed by the destination.

Returns:

the number of acquired messages processed by the destination.

getDiffMax

long getDiffMax()

Returns the maximum number of acquired messages waiting to be handled by the destination. When the number of messages waiting to be handled is greater the acquisition handler is temporarily stopped.

Returns:

the maximum number of acquired messages waiting to be handled by the destination.

getDiffMin

long getDiffMin()

Returns the minimum threshold of acquired messages waiting to be handled by the destination for restarting the acquisition handler.

Returns:

the minimum threshold of acquired messages waiting to be handled by the destination.

getPendingMax

long getPendingMax()

Returns the maximum number of waiting messages in the destination. When the number of waiting messages is greater the acquisition handler is temporarily stopped.

Returns:

the maximum number of waiting messages in the destination.

getPendingMin

long getPendingMin()

Returns the minimum threshold of waiting messages in the destination for restarting the acquisition handler.

Returns:

the minimum threshold of waiting messages in the destination.

dumpProperties

String dumpProperties()

isHandlerRunning

boolean isHandlerRunning()

Returns the acquisition handler status.

Returns:

the acquisition handler status.

start

void start()

Starts the handler.

stop

void stop()

Stops the handler.