QPID-2193: expose the deprecated deleteMessageFromTop() JMX queue operation for older brokers that lack the ability to delete arbitrary messages

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.5.x-dev@834450 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 29 insertions, 0 deletions

diff --git a/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java b/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
index 43d2cfe204..28f4c5acba 100644
--- a/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
+++ b/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java
@@ -399,6 +399,35 @@ public class QueueOperationsTabControl extends TabControl
             }
         });
         
+        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
         {