diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-06-28 16:46:12 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-06-28 16:46:12 +0000 |
| commit | 07c285f662e8f60d4e8aca247b65b77ca5df4587 (patch) | |
| tree | 7fe15262589c0fe5206e02a5e9336c6288f004e0 /qpid/java/management/common/src | |
| parent | bb45ec03f95ffdfa6c0163067dcb75af8b64ceb5 (diff) | |
| download | qpid-python-07c285f662e8f60d4e8aca247b65b77ca5df4587.tar.gz | |
QPID-3998, QPID-3999, QPID-4093: add new management plugins for jmx/rest/webui functionality, partial merge from the java-config-and-management branch at r1355039
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1355072 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/management/common/src')
2 files changed, 38 insertions, 8 deletions
diff --git a/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java b/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java index 254ec01519..b00b28b2a9 100644 --- a/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java +++ b/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ManagedQueue.java @@ -63,9 +63,14 @@ public interface ManagedQueue String ENCODING = "Encoding"; String CONTENT = "Content"; List<String> VIEW_MSG_CONTENT_COMPOSITE_ITEM_NAMES_DESC = Collections.unmodifiableList(Arrays.asList(MSG_AMQ_ID, MIME, ENCODING, CONTENT)); - + + /** Date/time format used for message expiration and message timestamp formatting */ + String JMSTIMESTAMP_DATETIME_FORMAT = "MM-dd-yy HH:mm:ss.SSS z"; + //Individual attribute name constants static final String ATTR_NAME = "Name"; + static final String ATTR_DESCRIPTION = "Description"; + static final String ATTR_QUEUE_TYPE = "QueueType"; static final String ATTR_OWNER = "Owner"; static final String ATTR_MAX_MSG_AGE = "MaximumMessageAge"; static final String ATTR_MAX_MSG_COUNT = "MaximumMessageCount"; @@ -92,6 +97,8 @@ public interface ManagedQueue new HashSet<String>( Arrays.asList( ATTR_NAME, + ATTR_QUEUE_TYPE, + ATTR_DESCRIPTION, ATTR_OWNER, ATTR_MAX_MSG_AGE, ATTR_MAX_MSG_COUNT, @@ -235,7 +242,7 @@ public interface ManagedQueue * Tells the maximum number of messages that can be stored in the queue. * This is useful in setting the notifications or taking required * action is the number of message increase this limit. - * @return maximum muber of message allowed to be stored in the queue. + * @return maximum nuumber of message allowed to be stored in the queue. * @throws IOException */ Long getMaximumMessageCount() throws IOException; @@ -287,13 +294,33 @@ public interface ManagedQueue */ @MBeanAttribute(name="Capacity", description="The flow control Capacity (Bytes) of the queue") void setCapacity(Long value) throws IOException, IllegalArgumentException; + + /** + * Gets the free text queue description. + * @since Qpid JMX API 2.5 + */ + String getDescription(); + + /** + * Sets the free text queue description. + * @since Qpid JMX API 2.5 + */ + @MBeanAttribute(name="Description", description="Free text description of the queue") + void setDescription(String string); + + /** + * Gets the queue type + * @since Qpid JMX API 2.5 + */ + @MBeanAttribute(name="QueueType", description="Type of the queue e.g. standard, priority, etc") + String getQueueType(); /** * Returns the current flow control FlowResumeCapacity of the queue in bytes. * * @since Qpid JMX API 1.6 * @return Capacity below which flow resumes in bytes - * @throws IOException + * @throws IOExceptionm */ Long getFlowResumeCapacity() throws IOException; @@ -332,7 +359,7 @@ public interface ManagedQueue * @since Qpid JMX API 2.0 * @param exclusive the capacity in bytes * @throws IOException - * @throws JMException + * @throws JMException */ @MBeanAttribute(name="Exclusive", description="Whether the queue is Exclusive or not") void setExclusive(boolean exclusive) throws IOException, JMException; @@ -341,10 +368,13 @@ public interface ManagedQueue * Sets the Alternate Exchange for the queue, for use in dead letter queue functionality. * * @since Qpid JMX API 2.4 - * @param the name of the exchange to use. Specifying null or the empty string will clear the alternate exchange. + * @param exchangeName the name of the exchange to use. Specifying null or the empty string will clear the + * alternate exchange. * @throws IOException + * @throws JMException */ - void setAlternateExchange(String exchangeName) throws IOException; + @MBeanAttribute(name="AlternateExchange", description="Alternate exchange for the queue") + void setAlternateExchange(String exchangeName) throws IOException, JMException; /** * Returns the name of the Alternate Exchange for the queue, or null if there isn't one. @@ -353,7 +383,6 @@ public interface ManagedQueue * @return the name of the Alternate Exchange for the queue, or null if there isn't one * @throws IOException */ - @MBeanAttribute(name="AlternateExchange", description="Alternate exchange for the queue") String getAlternateExchange() throws IOException; //********** Operations *****************// @@ -473,4 +502,5 @@ public interface ManagedQueue @MBeanOperationParameter(name="to MessageId", description="to MessageId")long toMessageId, @MBeanOperationParameter(name= ManagedQueue.TYPE, description="to Queue Name")String toQueue) throws IOException, JMException; + } diff --git a/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java b/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java index 38b89b58c5..1a4715224f 100644 --- a/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java +++ b/qpid/java/management/common/src/main/java/org/apache/qpid/management/common/mbeans/ServerInformation.java @@ -46,7 +46,7 @@ public interface ServerInformation * Qpid JMX API 1.1 can be assumed. */ int QPID_JMX_API_MAJOR_VERSION = 2; - int QPID_JMX_API_MINOR_VERSION = 4; + int QPID_JMX_API_MINOR_VERSION = 5; /** |
