|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjavax.management.StandardMBean
org.apache.qpid.server.management.DefaultManagedObject
org.apache.qpid.server.management.AMQManagedObject
org.apache.qpid.server.queue.AMQQueueMBean
public class AMQQueueMBean
AMQQueueMBean is the management bean for an AMQQueue
.
Field Summary |
---|
Fields inherited from class org.apache.qpid.server.management.AMQManagedObject |
---|
_broadcaster, _logActor, _mbeanInfo, _notificationSequenceNumber |
Fields inherited from interface org.apache.qpid.management.common.mbeans.ManagedQueue |
---|
ATTR_ACTIVE_CONSUMER_COUNT, ATTR_AUTODELETE, ATTR_CAPACITY, ATTR_CONSUMER_COUNT, ATTR_DURABLE, ATTR_EXCLUSIVE, ATTR_FLOW_OVERFULL, ATTR_FLOW_RESUME_CAPACITY, ATTR_MAX_MSG_AGE, ATTR_MAX_MSG_COUNT, ATTR_MAX_MSG_SIZE, ATTR_MAX_QUEUE_DEPTH, ATTR_MSG_COUNT, ATTR_NAME, ATTR_OWNER, ATTR_QUEUE_DEPTH, ATTR_RCVD_MSG_COUNT, CONTENT, ENCODING, MIME, MSG_AMQ_ID, MSG_HEADER, MSG_QUEUE_POS, MSG_REDELIVERED, MSG_SIZE, QUEUE_ATTRIBUTES, TYPE, VIEW_MSG_CONTENT_COMPOSITE_ITEM_NAMES_DESC, VIEW_MSGS_COMPOSITE_ITEM_NAMES_DESC, VIEW_MSGS_TABULAR_UNIQUE_INDEX |
Fields inherited from interface org.apache.qpid.server.management.ManagedObject |
---|
DOMAIN |
Constructor Summary | |
---|---|
AMQQueueMBean(AMQQueue queue)
|
Method Summary | |
---|---|
void |
checkForNotification(ServerMessage msg)
Checks if there is any notification to be send to the listeners |
Long |
clearQueue()
Clears the queue of non-acquired messages |
void |
copyMessages(long fromMessageId,
long toMessageId,
String toQueueName)
|
void |
deleteMessageFromTop()
|
void |
deleteMessages(long fromMessageId,
long toMessageId)
|
Integer |
getActiveConsumerCount()
|
Long |
getCapacity()
|
Integer |
getConsumerCount()
|
Long |
getFlowResumeCapacity()
|
Notification |
getLastNotification()
|
Long |
getMaximumMessageAge()
|
Long |
getMaximumMessageCount()
|
Long |
getMaximumMessageSize()
|
Long |
getMaximumQueueDepth()
returns the maximum total size of messages(bytes) in the queue. |
Integer |
getMessageCount()
|
String |
getName()
|
MBeanNotificationInfo[] |
getNotificationInfo()
returns Notifications sent by this MBean. |
String |
getObjectInstanceName()
|
String |
getOwner()
|
ManagedObject |
getParentObject()
|
Long |
getQueueDepth()
returns the total size of messages(bytes) in the queue. |
Long |
getReceivedMessageCount()
|
boolean |
isAutoDelete()
|
boolean |
isDurable()
|
boolean |
isExclusive()
|
boolean |
isFlowOverfull()
|
void |
moveMessages(long fromMessageId,
long toMessageId,
String toQueueName)
|
void |
notifyClients(NotificationCheck notification,
AMQQueue queue,
String notificationMsg)
Sends the notification to the listeners |
void |
setCapacity(Long capacity)
|
void |
setExclusive(boolean exclusive)
|
void |
setFlowResumeCapacity(Long flowResumeCapacity)
|
void |
setMaximumMessageAge(Long maximumMessageAge)
|
void |
setMaximumMessageCount(Long value)
|
void |
setMaximumMessageSize(Long value)
|
void |
setMaximumQueueDepth(Long value)
|
CompositeData |
viewMessageContent(long msgId)
returns message content as byte array and related attributes for the given message id. |
TabularData |
viewMessages(int beginIndex,
int endIndex)
Deprecated. |
TabularData |
viewMessages(long startPosition,
long endPosition)
Returns the header contents of the messages stored in this queue in tabular form. |
Methods inherited from class org.apache.qpid.server.management.AMQManagedObject |
---|
addNotificationListener, getMBeanInfo, removeNotificationListener |
Methods inherited from class org.apache.qpid.server.management.DefaultManagedObject |
---|
getHierarchicalName, getHierarchicalType, getManagedObjectRegistry, getManagementInterface, getObjectName, getObjectNameForSingleInstanceMBean, getType, jmxEncode, register, toString, unregister |
Methods inherited from class javax.management.StandardMBean |
---|
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public AMQQueueMBean(AMQQueue queue) throws JMException
JMException
Method Detail |
---|
public ManagedObject getParentObject()
getParentObject
in interface ManagedObject
getParentObject
in class DefaultManagedObject
public String getObjectInstanceName()
getObjectInstanceName
in interface ManagedObject
public String getName()
getName
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public boolean isDurable()
isDurable
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public String getOwner()
getOwner
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public boolean isAutoDelete()
isAutoDelete
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Integer getMessageCount()
getMessageCount
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Long getMaximumMessageSize()
getMaximumMessageSize
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Long getMaximumMessageAge()
getMaximumMessageAge
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setMaximumMessageAge(Long maximumMessageAge)
setMaximumMessageAge
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setMaximumMessageSize(Long value)
setMaximumMessageSize
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Integer getConsumerCount()
getConsumerCount
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Integer getActiveConsumerCount()
getActiveConsumerCount
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Long getReceivedMessageCount()
getReceivedMessageCount
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Long getMaximumMessageCount()
getMaximumMessageCount
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setMaximumMessageCount(Long value)
setMaximumMessageCount
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Long getMaximumQueueDepth()
getMaximumQueueDepth
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setMaximumQueueDepth(Long value)
setMaximumQueueDepth
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public Long getQueueDepth() throws JMException
getQueueDepth
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
JMException
public Long getCapacity()
getCapacity
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setCapacity(Long capacity) throws IllegalArgumentException
setCapacity
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
IllegalArgumentException
public Long getFlowResumeCapacity()
getFlowResumeCapacity
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setFlowResumeCapacity(Long flowResumeCapacity) throws IllegalArgumentException
setFlowResumeCapacity
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
IllegalArgumentException
public boolean isFlowOverfull()
isFlowOverfull
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public boolean isExclusive()
isExclusive
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
public void setExclusive(boolean exclusive) throws JMException
setExclusive
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
JMException
public void checkForNotification(ServerMessage msg) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public void notifyClients(NotificationCheck notification, AMQQueue queue, String notificationMsg)
notifyClients
in interface QueueNotificationListener
public Notification getLastNotification()
public void deleteMessageFromTop() throws JMException
deleteMessageFromTop
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
JMException
AMQQueue.deleteMessageFromTop()
public Long clearQueue() throws JMException
clearQueue
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
JMException
AMQQueue.clearQueue()
public CompositeData viewMessageContent(long msgId) throws JMException
viewMessageContent
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
JMException
@Deprecated public TabularData viewMessages(int beginIndex, int endIndex) throws JMException
viewMessages
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
JMException
public TabularData viewMessages(long startPosition, long endPosition) throws JMException
viewMessages
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
startPosition
- The queue position of the first message to be viewedendPosition
- The queue position of the last message to be viewed
JMException
public void moveMessages(long fromMessageId, long toMessageId, String toQueueName) throws JMException
moveMessages
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
fromMessageId
- toMessageId
- toQueueName
-
JMException
ManagedQueue.moveMessages(long, long, java.lang.String)
public void deleteMessages(long fromMessageId, long toMessageId) throws JMException
deleteMessages
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
fromMessageId
- toMessageId
-
JMException
ManagedQueue.deleteMessages(long, long)
public void copyMessages(long fromMessageId, long toMessageId, String toQueueName) throws JMException
copyMessages
in interface org.apache.qpid.management.common.mbeans.ManagedQueue
fromMessageId
- toMessageId
- toQueueName
-
JMException
ManagedQueue.copyMessages(long, long, java.lang.String)
public MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo
in interface NotificationBroadcaster
getNotificationInfo
in class AMQManagedObject
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |