diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java index ff5302f3b1..0fadf25d6e 100644 --- a/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java +++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java @@ -2793,4 +2793,28 @@ public interface AuditLogger extends BasicLogger { @LogMessage(level = Logger.Level.INFO) @Message(id = 601742, value = "User {0} is getting the queue count on target resource: {1} {2}", format = Message.Format.MESSAGE_FORMAT) void getQueueCount(String user, Object source, Object... args); + + static void lastValueKey(Object source) { + LOGGER.lastValueKey(getCaller(), source); + } + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 601743, value = "User {0} is getting last-value-key property on target resource: {1} {2}", format = Message.Format.MESSAGE_FORMAT) + void lastValueKey(String user, Object source, Object... args); + + static void consumersBeforeDispatch(Object source) { + LOGGER.consumersBeforeDispatch(getCaller(), source); + } + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 601744, value = "User {0} is getting consumers-before-dispatch property on target resource: {1} {2}", format = Message.Format.MESSAGE_FORMAT) + void consumersBeforeDispatch(String user, Object source, Object... args); + + static void delayBeforeDispatch(Object source) { + LOGGER.delayBeforeDispatch(getCaller(), source); + } + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 601745, value = "User {0} is getting delay-before-dispatch property on target resource: {1} {2}", format = Message.Format.MESSAGE_FORMAT) + void delayBeforeDispatch(String user, Object source, Object... args); } diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/QueueControl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/QueueControl.java index b6ba1e1865..414a9da69b 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/QueueControl.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/QueueControl.java @@ -290,6 +290,26 @@ public interface QueueControl { @Attribute(desc = "is this queue a last value queue") boolean isLastValue(); + /** + *The key used for the last value queues + */ + @Attribute(desc = "last value key") + String getLastValueKey(); + + /** + *Return the Consumers Before Dispatch + * @return + */ + @Attribute(desc = "Return the Consumers Before Dispatch") + int getConsumersBeforeDispatch(); + + /** + *Return the Consumers Before Dispatch + * @return + */ + @Attribute(desc = "Return the Consumers Before Dispatch") + long getDelayBeforeDispatch(); + // Operations ---------------------------------------------------- /** diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisPlugin.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisPlugin.js index 1cec98f3f4..9e7d49949a 100644 --- a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisPlugin.js +++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisPlugin.js @@ -46,6 +46,7 @@ var Artemis = (function (Artemis) {
+
diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/addresses.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/addresses.js index 6aa87c8c5c..d15a3a27ba 100644 --- a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/addresses.js +++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/addresses.js @@ -28,6 +28,7 @@ var Artemis;
@@ -59,17 +60,48 @@ var Artemis; function AddressesController($scope, workspace, jolokia, localStorage, artemisMessage, $location, $timeout, $filter, $sanitize, pagination, artemisAddress) { var ctrl = this; ctrl.pagination = pagination; + ctrl.pagination.reset(); var mbean = Artemis.getBrokerMBean(workspace, jolokia); ctrl.allAddresses = []; ctrl.addresses = []; ctrl.workspace = workspace; ctrl.refreshed = false; + ctrl.dtOptions = { + // turn of ordering as we do it ourselves + ordering: false, + columns: [ + {name: "ID", visible: true}, + {name: "Name", visible: true}, + {name: "Routing Types", visible: true}, + {name: "Queue Count", visible: true} + ] + }; + + Artemis.log.debug('sessionStorage: addressColumnDefs =', localStorage.getItem('addressColumnDefs')); + if (localStorage.getItem('addressColumnDefs')) { + loadedDefs = JSON.parse(localStorage.getItem('addressColumnDefs')); + //sanity check to make sure columns havent been added + if(loadedDefs.length === ctrl.dtOptions.columns.length) { + ctrl.dtOptions.columns = loadedDefs; + } + + } + + ctrl.updateColumns = function () { + var attributes = []; + ctrl.dtOptions.columns.forEach(function (column) { + attributes.push({name: column.name, visible: column.visible}); + }); + Artemis.log.debug("saving columns " + JSON.stringify(attributes)); + localStorage.setItem('addressColumnDefs', JSON.stringify(attributes)); + } + ctrl.filter = { fieldOptions: [ - {id: 'ID', name: 'ID'}, - {id: 'NAME', name: 'Name'}, - {id: 'ROUTING_TYPES', name: 'Queue Count'}, - {id: 'QUEUE_COUNT', name: 'User'} + {id: 'id', name: 'ID'}, + {id: 'name', name: 'Name'}, + {id: 'routingTypes', name: 'Routing Types'}, + {id: 'queueCount', name: 'Queue Count'} ], operationOptions: [ {id: 'EQUALS', name: 'Equals'}, @@ -139,6 +171,7 @@ var Artemis; ctrl.filter.values.field = ctrl.filter.fieldOptions[1].id; ctrl.filter.values.operation = ctrl.filter.operationOptions[0].id; ctrl.filter.values.value = artemisAddress.address.address; + artemisAddress.address = null; } selectQueues = function (idx) { diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js index 27e3ed4e34..4780a2a528 100644 --- a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js +++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js @@ -65,6 +65,11 @@ var Artemis; ng-disabled="$ctrl.retryDisabled" ng-click="$ctrl.openRetryDialog()">Retry Messages + @@ -72,7 +77,7 @@ var Artemis;
@@ -147,6 +152,33 @@ var Artemis;

{{$ctrl.actionText}}

+
+ + +