diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/queue.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/queue.js index 1cfb2de551..d4c8b4223a 100644 --- a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/queue.js +++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/queue.js @@ -119,14 +119,14 @@ var ARTEMIS = (function(ARTEMIS) { $scope.purgeDestination = function () { var selection = workspace.selection; var entries = selection.entries; - var mbean = getBrokerMBean(jolokia); + var mbean = selection.objectName; if (mbean) { if (selection && jolokia && entries) { var name = entries["Destination"] || entries["destinationName"] || selection.title; name = name.unescapeHTML(); var operation = "purge()"; $scope.message = "Purged queue " + name; - ARTEMISService.artemisConsole.purgeQueue(mbean, jolokia, name, onSuccess(deleteSuccess)); + ARTEMISService.artemisConsole.purgeQueue(mbean, jolokia, onSuccess(deleteSuccess)); } } }; diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/lib/artemis-console.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/lib/artemis-console.js index 89a88ef719..4ef90d5b37 100644 --- a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/lib/artemis-console.js +++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/lib/artemis-console.js @@ -38,8 +38,8 @@ function ArtemisConsole() { jolokia.execute(mbean, "destroyQueue(java.lang.String)", name, method); }; - this.purgeQueue = function (mbean, jolokia, name, method) { - //todo + this.purgeQueue = function (mbean, jolokia, method) { + jolokia.execute(mbean, "removeAllMessages()", method); }; this.browse = function (mbean, jolokia, method) {