diff options
author | Robert Gemmell <robbie@apache.org> | 2010-07-16 15:19:46 +0000 |
---|---|---|
committer | Robert Gemmell <robbie@apache.org> | 2010-07-16 15:19:46 +0000 |
commit | ee7232042d82b6ce63c6398d61fa518e7beec4e3 (patch) | |
tree | a197cbfe30bf8a472ce7bedf851352cf8db13d5f /java/management/common/src | |
parent | 9f89d600074f5e9f800d202e948adbe131cee5e8 (diff) | |
download | qpid-python-ee7232042d82b6ce63c6398d61fa518e7beec4e3.tar.gz |
QPID-2731: enable getting/setting queue exclusivity via JMX
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964825 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/management/common/src')
3 files changed, 26 insertions, 4 deletions
diff --git a/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedExchange.java b/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedExchange.java index 50acc264e6..e5ca69eabb 100644 --- a/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedExchange.java +++ b/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedExchange.java @@ -112,7 +112,7 @@ public interface ManagedExchange * @param routingKey the routing key * @throws IOException * @throws JMException - * @since 1.8 + * @since Qpid JMX API 1.8 */ @MBeanOperation(name="removeBinding", description="Removes an exchange binding from the Queue", diff --git a/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java b/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java index 282fc86ced..20e97adf8c 100644 --- a/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java +++ b/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java @@ -70,6 +70,7 @@ public interface ManagedQueue String ATTR_CAPACITY = "Capacity"; String ATTR_FLOW_OVERFULL = "FlowOverfull"; String ATTR_FLOW_RESUME_CAPACITY = "FlowResumeCapacity"; + String ATTR_EXCLUSIVE = "Exclusive"; //All attribute names constant String[] QUEUE_ATTRIBUTES = new String[]{ @@ -88,7 +89,8 @@ public interface ManagedQueue ATTR_RCVD_MSG_COUNT, ATTR_CAPACITY, ATTR_FLOW_OVERFULL, - ATTR_FLOW_RESUME_CAPACITY + ATTR_FLOW_RESUME_CAPACITY, + ATTR_EXCLUSIVE }; /** @@ -285,6 +287,26 @@ public interface ManagedQueue */ @MBeanAttribute(name="FlowOverfull", description="true if the queue is considered overfull by the Flow Control system") boolean isFlowOverfull() throws IOException; + + /** + * Returns whether the queue is exclusive or not. + * + * @since Qpid JMX API 2.0 + * @return whether the queue is exclusive. + * @throws IOException + */ + boolean isExclusive() throws IOException; + + /** + * Sets whether the queue is exclusive or not. + * + * @since Qpid JMX API 2.0 + * @param exclusive the capacity in bytes + * @throws IOException + * @throws JMException + */ + @MBeanAttribute(name="Exclusive", description="Whether the queue is Exclusive or not") + void setExclusive(boolean exclusive) throws IOException, JMException; //********** Operations *****************// diff --git a/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java b/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java index f61c41dea9..618403fdca 100644 --- a/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java +++ b/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java @@ -41,8 +41,8 @@ public interface ServerInformation * indicates that version. If it is not present then a null value will be returned upon inspection and * Qpid JMX API 1.1 can be assumed. */ - int QPID_JMX_API_MAJOR_VERSION = 1; - int QPID_JMX_API_MINOR_VERSION = 8; + int QPID_JMX_API_MAJOR_VERSION = 2; + int QPID_JMX_API_MINOR_VERSION = 0; /** |