Author: robbie
Date: Tue Nov 10 12:22:21 2009
New Revision: 834450
URL: http://svn.apache.org/viewvc?rev=834450&view=rev
Log:
QPID-2193: expose the deprecated deleteMessageFromTop() JMX queue operation for
older brokers that lack the ability to delete arbitrary messages
Modified:
qpid/branches/0.5.x-dev/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
Modified:
qpid/branches/0.5.x-dev/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
URL:
http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java?rev=834450&r1=834449&r2=834450&view=diff
==============================================================================
---
qpid/branches/0.5.x-dev/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
(original)
+++
qpid/branches/0.5.x-dev/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
Tue Nov 10 12:22:21 2009
@@ -399,6 +399,35 @@
}
});
+ if(_ApiVersion.lessThan(1, 3)) //if the server predates Qpid JMX API
1.3
+ {
+ final Button deleteFirstMessageButton =
_toolkit.createButton(buttonsComposite, "Delete 1st Unacquired Msg", SWT.PUSH);
+ deleteFirstMessageButton.setLayoutData(new GridData(SWT.FILL,
SWT.TOP, false, false));
+ deleteFirstMessageButton.addSelectionListener(new
SelectionAdapter()
+ {
+ public void widgetSelected(SelectionEvent se)
+ {
+ int response =
ViewUtility.popupOkCancelConfirmationMessage("Delete 1st unacquired message",
+
"Delete 1st unacquired message on the queue?");
+ if (response == SWT.OK)
+ {
+ try
+ {
+ _qmb.deleteMessageFromTop();
+ ViewUtility.operationResultFeedback(null, "Deleted
1st unacquired message on the queue", null);
+ }
+ catch (Exception e)
+ {
+ ViewUtility.operationFailedStatusBarMessage("Error
deleting 1st unacquired message on queue");
+ MBeanUtility.handleException(_mbean, e);
+ }
+
+ refresh(_mbean);;
+ }
+ }
+ });
+ }
+
final Button copyMessagesButton;
if(_ApiVersion.greaterThanOrEqualTo(1, 3))//if the server supports
Qpid JMX API 1.3
{
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
