Package org.objectweb.joram.mom.dest
Interface QueueMBean
-
- All Superinterfaces:
AgentMBean,DestinationMBean
- All Known Subinterfaces:
AcquisitionQueueMBean,ClusterQueueMBean,DistributionQueueMBean
- All Known Implementing Classes:
AcquisitionQueue,AliasInQueue,AliasQueue,ClusterQueue,DistributionQueue,FtpQueue,Queue,SchedulerQueue
public interface QueueMBean extends DestinationMBean
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcleanPendingMessage()Removes all messages that the time-to-live is expired.voidcleanWaitingRequest()Removes all request that the expiration time is expired.voidclear()Removes all pending messages.voidexportMessages(String dirpath, String selector, boolean quiet)Exports all messages in the specified directory.longgetConsumerLoad()Return the average consumer's load during last moments.CompositeDatagetDelayedMessage(String msgId)Returns the description of a particular delayed message.intgetDelayedMessageCount()Returns the number of messages waiting for a delay.TabularDatagetDelayedMessages()Returns the description of all delayed messages.intgetDeliveredMessageCount()Returns the number of messages delivered and waiting for acknowledge.intgetDeliveryDelay()Returns the Queue deliveryDelay in milliseconds.CompositeDatagetMessage(String msgId)Returns the description of a particular pending message.TabularDatagetMessages()Returns the description of all pending messages.intgetNbMaxMsg()Returns the maximum number of message for the destination.longgetNbMsgsDeniedSinceCreation()Returns the number of messages denied since creation time of this destination.intgetPendingMessageCount()Returns the number of pending messages in the queue.longgetProducerLoad()Return the average producer's load during last moments.intgetRedeliveryDelay()Return the reDeliveryDelay (unit: second)intgetThreshold()Returns the threshold value of this queue, -1 if not set.intgetWaitingRequestCount()Returns the number of waiting requests in the queue.booleanisPause()voidsetDeliveryDelay(int deliveryDelay)Sets the Queue deliveryDelay in milliseconds.voidsetNbMaxMsg(int nbMaxMsg)Sets the maximum number of message for the destination.voidsetPause(boolean pause)voidsetRedeliveryDelay(int reDeliveryDelay)voidsetThreshold(int threshold)Sets or unsets the threshold for this queue.-
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
-
-
-
-
Method Detail
-
getThreshold
int getThreshold()
Returns the threshold value of this queue, -1 if not set.- Returns:
- the threshold value of this queue; -1 if not set.
-
setThreshold
void setThreshold(int threshold)
Sets or unsets the threshold for this queue.- Parameters:
threshold- The threshold value to be set or -1 for unsetting previous value.
-
getWaitingRequestCount
int getWaitingRequestCount()
Returns the number of waiting requests in the queue.- Returns:
- The number of waiting requests.
-
cleanWaitingRequest
void cleanWaitingRequest() throws ExceptionRemoves all request that the expiration time is expired.- Throws:
Exception
-
getPendingMessageCount
int getPendingMessageCount()
Returns the number of pending messages in the queue.- Returns:
- The number of pending messages.
-
getDelayedMessageCount
int getDelayedMessageCount()
Returns the number of messages waiting for a delay.- Returns:
- The number of messages waiting for a delay.
-
getProducerLoad
long getProducerLoad()
Return the average producer's load during last moments.
-
getConsumerLoad
long getConsumerLoad()
Return the average consumer's load during last moments.
-
cleanPendingMessage
void cleanPendingMessage() throws ExceptionRemoves all messages that the time-to-live is expired.- Throws:
Exception
-
getDeliveredMessageCount
int getDeliveredMessageCount()
Returns the number of messages delivered and waiting for acknowledge.- Returns:
- The number of messages delivered.
-
getNbMsgsDeniedSinceCreation
long getNbMsgsDeniedSinceCreation()
Returns the number of messages denied since creation time of this destination.- Returns:
- the number of messages delivered since creation time.
-
getNbMaxMsg
int getNbMaxMsg()
Returns the maximum number of message for the destination. If the limit is unset the method returns -1.- Returns:
- the maximum number of message for subscription if set; -1 otherwise.
-
setNbMaxMsg
void setNbMaxMsg(int nbMaxMsg)
Sets the maximum number of message for the destination.- Parameters:
nbMaxMsg- the maximum number of message (-1 set no limit).
-
getMessage
CompositeData getMessage(String msgId) throws Exception
Returns the description of a particular pending message. The message is pointed out through its unique identifier.- Parameters:
msgId- The unique message's identifier.- Returns:
- the description of the message.
- Throws:
Exception- See Also:
MessageJMXWrapper
-
getMessages
TabularData getMessages() throws Exception
Returns the description of all pending messages.- Returns:
- the description of the message.
- Throws:
Exception- See Also:
MessageJMXWrapper
-
getDelayedMessage
CompositeData getDelayedMessage(String msgId) throws Exception
Returns the description of a particular delayed message. The message is pointed out through its unique identifier.- Parameters:
msgId- The unique message's identifier.- Returns:
- the description of the message.
- Throws:
Exception- See Also:
MessageJMXWrapper
-
getDelayedMessages
TabularData getDelayedMessages() throws Exception
Returns the description of all delayed messages.- Returns:
- the description of the message.
- Throws:
Exception- See Also:
MessageJMXWrapper
-
getRedeliveryDelay
int getRedeliveryDelay()
Return the reDeliveryDelay (unit: second)
-
setRedeliveryDelay
void setRedeliveryDelay(int reDeliveryDelay)
- Parameters:
reDeliveryDelay- the reDeliveryDelay to set(unit: second)
-
getDeliveryDelay
int getDeliveryDelay()
Returns the Queue deliveryDelay in milliseconds.- Returns:
- the DeliveryDelay
-
setDeliveryDelay
void setDeliveryDelay(int deliveryDelay)
Sets the Queue deliveryDelay in milliseconds.- Parameters:
deliveryDelay- the deliveryDelay to set
-
isPause
boolean isPause()
-
setPause
void setPause(boolean pause)
-
exportMessages
void exportMessages(String dirpath, String selector, boolean quiet) throws Exception
Exports all messages in the specified directory. Options? filtrage? Format?- Throws:
Exception
-
clear
void clear()
Removes all pending messages.
-
-