public interface QueueMBean extends DestinationMBean
Modifier and Type | Method and Description |
---|---|
void |
cleanPendingMessage()
Removes all messages that the time-to-live is expired.
|
void |
cleanWaitingRequest()
Removes all request that the expiration time is expired.
|
long |
getConsumerLoad()
Return the average consumer's load during last moments.
|
int |
getDelayedMessageCount()
Returns the number of messages waiting for a delay.
|
int |
getDeliveredMessageCount()
Returns the number of messages delivered and waiting for acknowledge.
|
int |
getDeliveryDelay()
Returns the Queue deliveryDelay in milliseconds.
|
CompositeData |
getMessage(String msgId)
Returns the description of a particular pending message.
|
TabularData |
getMessages()
Returns the description of all pending messages.
|
int |
getNbMaxMsg()
Returns the maximum number of message for the destination.
|
long |
getNbMsgsDeniedSinceCreation()
Returns the number of messages denied since creation time of this
destination.
|
int |
getPendingMessageCount()
Returns the number of pending messages in the queue.
|
long |
getProducerLoad()
Return the average producer's load during last moments.
|
int |
getRedeliveryDelay()
Return the reDeliveryDelay (unit: second)
|
int |
getThreshold()
Returns the threshold value of this queue, -1 if not set.
|
int |
getWaitingRequestCount()
Returns the number of waiting requests in the queue.
|
boolean |
isPause() |
void |
setDeliveryDelay(int deliveryDelay)
Sets the Queue deliveryDelay in milliseconds.
|
void |
setNbMaxMsg(int nbMaxMsg)
Sets the maximum number of message for the destination.
|
void |
setPause(boolean pause) |
void |
setRedeliveryDelay(int reDeliveryDelay) |
void |
setThreshold(int threshold)
Sets or unsets the threshold for this queue.
|
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getType, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod, toString
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
int getThreshold()
void setThreshold(int threshold)
threshold
- The threshold value to be set or -1 for unsetting
previous value.int getWaitingRequestCount()
void cleanWaitingRequest()
int getPendingMessageCount()
int getDelayedMessageCount()
long getProducerLoad()
long getConsumerLoad()
void cleanPendingMessage()
int getDeliveredMessageCount()
long getNbMsgsDeniedSinceCreation()
int getNbMaxMsg()
void setNbMaxMsg(int nbMaxMsg)
nbMaxMsg
- the maximum number of message (-1 set no limit).CompositeData getMessage(String msgId) throws Exception
msgId
- The unique message's identifier.Exception
MessageJMXWrapper
TabularData getMessages() throws Exception
Exception
MessageJMXWrapper
int getRedeliveryDelay()
void setRedeliveryDelay(int reDeliveryDelay)
reDeliveryDelay
- the reDeliveryDelay to set(unit: second)int getDeliveryDelay()
void setDeliveryDelay(int deliveryDelay)
deliveryDelay
- the deliveryDelay to setboolean isPause()
void setPause(boolean pause)
Copyright © 2019 ScalAgent D.T.. All rights reserved.