+
+
diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/address.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/address.js
new file mode 100644
index 0000000000..cc0aef1a30
--- /dev/null
+++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/address.js
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * @module ARTEMIS
+ */
+var ARTEMIS = (function(ARTEMIS) {
+
+ /**
+ * @method AddressController
+ * @param $scope
+ * @param ARTEMISService
+ *
+ * Controller for the Create interface
+ */
+ ARTEMIS.AddressController = function ($scope, workspace, ARTEMISService, jolokia, localStorage) {
+ Core.initPreferenceScope($scope, localStorage, {
+ 'routingType': {
+ 'value': 0,
+ 'converter': parseInt,
+ 'formatter': parseInt
+ }
+ });
+ var artemisJmxDomain = localStorage['artemisJmxDomain'] || "org.apache.activemq.artemis";
+ $scope.workspace = workspace;
+ $scope.message = "";
+ $scope.deleteDialog = false;
+ $scope.$watch('workspace.selection', function () {
+ workspace.moveIfViewInvalid();
+ });
+ function operationSuccess() {
+ $scope.addressName = "";
+ $scope.workspace.operationCounter += 1;
+ Core.$apply($scope);
+ Core.notification("success", $scope.message);
+ $scope.workspace.loadTree();
+ }
+ function deleteSuccess() {
+ // lets set the selection to the parent
+ workspace.removeAndSelectParentNode();
+ $scope.workspace.operationCounter += 1;
+ Core.$apply($scope);
+ Core.notification("success", $scope.message);
+ $scope.workspace.loadTree();
+ }
+ $scope.createAddress = function (name, routingType) {
+ var mbean = getBrokerMBean(jolokia);
+ if (mbean) {
+ if (routingType == 0) {
+ $scope.message = "Created Multicast Address " + name;
+ ARTEMIS.log.info($scope.message);
+ ARTEMISService.artemisConsole.createAddress(mbean, jolokia, name, "MULTICAST", onSuccess(operationSuccess));
+ }
+ else if (routingType == 1) {
+ $scope.message = "Created Anycast Address " + name;
+ ARTEMIS.log.info($scope.message);
+ ARTEMISService.artemisConsole.createAddress(mbean, jolokia, name, "ANYCAST", onSuccess(operationSuccess));
+ }
+ else {
+ $scope.message = "Created Anycast/Multicast Address " + name;
+ ARTEMIS.log.info($scope.message);
+ ARTEMISService.artemisConsole.createAddress(mbean, jolokia, name, "ANYCAST,MULTICAST", onSuccess(operationSuccess));
+ }
+ }
+ };
+ $scope.deleteAddress = function () {
+ var selection = workspace.selection;
+ var entries = selection.entries;
+ var mbean = getBrokerMBean(jolokia);
+ ARTEMIS.log.info(mbean);
+ if (mbean) {
+ if (selection && jolokia && entries) {
+ var domain = selection.domain;
+ var name = entries["name"];
+ name = name.unescapeHTML();
+ if (name.charAt(0) === '"' && name.charAt(name.length -1) === '"')
+ {
+ name = name.substr(1,name.length -2);
+ }
+ ARTEMIS.log.info(name);
+ var operation;
+ $scope.message = "Deleted address " + name;
+ ARTEMISService.artemisConsole.deleteAddress(mbean, jolokia, name, onSuccess(deleteSuccess));
+ }
+ }
+ };
+ $scope.name = function () {
+ var selection = workspace.selection;
+ if (selection) {
+ return selection.title;
+ }
+ return null;
+ };
+
+ function getBrokerMBean(jolokia) {
+ var mbean = null;
+ var selection = workspace.selection;
+ var folderNames = selection.folderNames;
+ mbean = "" + folderNames[0] + ":broker=" + folderNames[1];
+ ARTEMIS.log.info("broker=" + mbean);
+ return mbean;
+ }
+ };
+
+ return ARTEMIS;
+} (ARTEMIS || {}));
\ No newline at end of file
diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisHelpers.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisHelpers.js
new file mode 100644
index 0000000000..210c52a4be
--- /dev/null
+++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisHelpers.js
@@ -0,0 +1,126 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+var ARTEMIS;
+(function (ARTEMIS) {
+ ARTEMIS.log = Logger.get("ARTEMIS");
+ ARTEMIS.jmxDomain = 'org.apache.ARTEMIS';
+ function getSelectionQueuesFolder(workspace) {
+ function findQueuesFolder(node) {
+ if (node) {
+ if (node.title === "Queues" || node.title === "Queue") {
+ return node;
+ }
+ var parent = node.parent;
+ if (parent) {
+ return findQueuesFolder(parent);
+ }
+ }
+ return null;
+ }
+ var selection = workspace.selection;
+ if (selection) {
+ return findQueuesFolder(selection);
+ }
+ return null;
+ }
+ ARTEMIS.getSelectionQueuesFolder = getSelectionQueuesFolder;
+ function getSelectionTopicsFolder(workspace) {
+ function findTopicsFolder(node) {
+ var answer = null;
+ if (node) {
+ if (node.title === "Topics" || node.title === "Topic") {
+ answer = node;
+ }
+ if (answer === null) {
+ angular.forEach(node.children, function (child) {
+ if (child.title === "Topics" || child.title === "Topic") {
+ answer = child;
+ }
+ });
+ }
+ }
+ return answer;
+ }
+ var selection = workspace.selection;
+ if (selection) {
+ return findTopicsFolder(selection);
+ }
+ return null;
+ }
+ ARTEMIS.getSelectionTopicsFolder = getSelectionTopicsFolder;
+ /**
+ * Sets $scope.row to currently selected JMS message.
+ * Used in:
+ * - ARTEMIS/js/browse.ts
+ * - camel/js/browseEndpoint.ts
+ *
+ * TODO: remove $scope argument and operate directly on other variables. but it's too much side effects here...
+ *
+ * @param message
+ * @param key unique key inside message that distinguishes between values
+ * @param $scope
+ */
+ function selectCurrentMessage(message, key, $scope) {
+ // clicking on message's link would interfere with messages selected with checkboxes
+ $scope.gridOptions.selectAll(false);
+ var idx = Core.pathGet(message, ["rowIndex"]);
+ var jmsMessageID = Core.pathGet(message, ["entity", key]);
+ $scope.rowIndex = idx;
+ var selected = $scope.gridOptions.selectedItems;
+ selected.splice(0, selected.length);
+ if (idx >= 0 && idx < $scope.messages.length) {
+ $scope.row = $scope.messages.find(function (msg) { return msg[key] === jmsMessageID; });
+ if ($scope.row) {
+ selected.push($scope.row);
+ }
+ }
+ else {
+ $scope.row = null;
+ }
+ }
+ ARTEMIS.selectCurrentMessage = selectCurrentMessage;
+ /**
+ * - Adds functions needed for message browsing with details
+ * - Adds a watch to deselect all rows after closing the slideout with message details
+ * TODO: export these functions too?
+ *
+ * @param $scope
+ */
+ function decorate($scope) {
+ $scope.selectRowIndex = function (idx) {
+ $scope.rowIndex = idx;
+ var selected = $scope.gridOptions.selectedItems;
+ selected.splice(0, selected.length);
+ if (idx >= 0 && idx < $scope.messages.length) {
+ $scope.row = $scope.messages[idx];
+ if ($scope.row) {
+ selected.push($scope.row);
+ }
+ }
+ else {
+ $scope.row = null;
+ }
+ };
+ $scope.$watch("showMessageDetails", function () {
+ if (!$scope.showMessageDetails) {
+ $scope.row = null;
+ $scope.gridOptions.selectedItems.splice(0, $scope.gridOptions.selectedItems.length);
+ }
+ });
+ }
+ ARTEMIS.decorate = decorate;
+})(ARTEMIS || (ARTEMIS = {}));
\ No newline at end of file
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
new file mode 100644
index 0000000000..6f791698cc
--- /dev/null
+++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisPlugin.js
@@ -0,0 +1,246 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * @module ARTEMIS
+ * @main ARTEMIS
+ *
+ * The main entrypoint for the ARTEMIS module
+ *
+ */
+var ARTEMIS = (function(ARTEMIS) {
+
+ /**
+ * @property pluginName
+ * @type {string}
+ *
+ * The name of this plugin
+ */
+ ARTEMIS.pluginName = "ARTEMIS";
+
+ /**
+ * @property log
+ * @type {Logging.Logger}
+ *
+ * This plugin's logger instance
+ */
+ ARTEMIS.log = Logger.get(ARTEMIS.pluginName);
+
+ /**
+ * @property templatePath
+ * @type {string}
+ *
+ * The top level path to this plugin's partials
+ */
+ ARTEMIS.templatePath = "../artemis-plugin/plugin/html/";
+
+ /**
+ * @property jmxDomain
+ * @type {string}
+ *
+ * The JMX domain this plugin mostly works with
+ */
+ ARTEMIS.jmxDomain = "hawtio"
+
+ /**
+ * @property mbeanType
+ * @type {string}
+ *
+ * The mbean type this plugin will work with
+ */
+ ARTEMIS.mbeanType = "ARTEMISHandler";
+
+ /**
+ * @property mbean
+ * @type {string}
+ *
+ * The mbean's full object name
+ */
+ ARTEMIS.mbean = ARTEMIS.jmxDomain + ":type=" + ARTEMIS.mbeanType;
+
+ /**
+ * @property SETTINGS_KEY
+ * @type {string}
+ *
+ * The key used to fetch our settings from local storage
+ */
+ ARTEMIS.SETTINGS_KEY = 'ARTEMISSettings';
+
+ /**
+ * @property module
+ * @type {object}
+ *
+ * This plugin's angularjs module instance
+ */
+ ARTEMIS.module = angular.module(ARTEMIS.pluginName, ['bootstrap', 'ngResource', 'ui.bootstrap.dialog', 'hawtioCore', 'camel', 'hawtio-ui']);
+
+ // set up the routing for this plugin, these are referenced by the subleveltabs added below
+ ARTEMIS.module.config(function($routeProvider) {
+ $routeProvider
+ .when('/artemis/createAddress', {
+ templateUrl: ARTEMIS.templatePath + 'createAddress.html'
+ })
+ .when('/artemis/deleteAddress', {
+ templateUrl: ARTEMIS.templatePath + 'deleteAddress.html'
+ })
+ .when('/artemis/deleteQueue', {
+ templateUrl: ARTEMIS.templatePath + 'deleteQueue.html'
+ })
+ .when('/artemis/createQueue', {
+ templateUrl: ARTEMIS.templatePath + 'createQueue.html'
+ })
+ .when('/artemis/browseQueue', {
+ templateUrl: ARTEMIS.templatePath + 'browseQueue.html'
+ })
+ .when('/artemis/diagram', {
+ templateUrl: ARTEMIS.templatePath + 'brokerDiagram.html'
+ })
+ .when('/artemis/sendMessage', {
+ templateUrl: ARTEMIS.templatePath + 'sendMessage.html'
+ });
+ });
+
+ ARTEMIS.module.factory('artemisMessage', function () {
+ return { 'message': null };
+ });
+
+ // one-time initialization happens in the run function
+ // of our module
+ ARTEMIS.module.run(function(workspace, viewRegistry, helpRegistry, preferencesRegistry, localStorage, jolokia, ARTEMISService, $rootScope) {
+ // let folks know we're actually running
+ ARTEMIS.log.info("plugin running " + jolokia);
+
+ var artemisJmxDomain = localStorage['artemisJmxDomain'] || "org.apache.activemq.artemis";
+
+ ARTEMISService.initArtemis();
+
+ // tell hawtio that we have our own custom layout for
+ // our view
+ viewRegistry["artemis"] = ARTEMIS.templatePath + "artemisLayout.html";
+
+ helpRegistry.addUserDoc("artemis", "../artemis-plugin/plugin/doc/help.md", function () {
+ return workspace.treeContainsDomainAndProperties(artemisJmxDomain);
+ });
+
+ preferencesRegistry.addTab("Artemis", ARTEMIS.templatePath + "preferences.html", function () {
+ return workspace.treeContainsDomainAndProperties(artemisJmxDomain);
+ });
+
+ // Add a top level tab to hawtio's navigation bar
+ workspace.topLevelTabs.push({
+ id: "artemis",
+ content: "Artemis",
+ title: "Artemis Broker",
+ isValid: function (workspace) {
+ return workspace.treeContainsDomainAndProperties(artemisJmxDomain);
+ },
+ href: function () {
+ return "#/jmx/attributes?tab=artemis";
+ },
+ isActive: function () {
+ return workspace.isLinkActive("artemis");
+ }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Create',
+ title: "Create a new address",
+ isValid: function (workspace) {
+ return isBroker(workspace, artemisJmxDomain) || isAddressFolder(workspace, artemisJmxDomain);
+ },
+ href: function () {
+ return "#/artemis/createAddress";
+ }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Delete',
+ title: "Delete an address",
+ isValid: function (workspace) {
+ return isAddress(workspace, artemisJmxDomain);
+ },
+ href: function () {
+ return "#/artemis/deleteAddress";
+ }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Create',
+ title: "Create a new queue",
+ isValid: function (workspace) {
+ return isAddress(workspace, artemisJmxDomain)
+ },
+ href: function () {
+ return "#/artemis/createQueue"
+ }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Delete',
+ title: "Delete or purge this queue",
+ isValid: function (workspace) {
+ return isQueue(workspace, artemisJmxDomain)
+ },
+ href: function () {
+ return "#/artemis/deleteQueue"
+ }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Browse',
+ title: "Browse the messages on the queue",
+ isValid: function (workspace) { return isQueue(workspace, artemisJmxDomain); },
+ href: function () { return "#/artemis/browseQueue"; }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Send',
+ title: "Send a message to this address",
+ isValid: function (workspace) { return isAddress(workspace, artemisJmxDomain) || isQueue(workspace, artemisJmxDomain); },
+ href: function () { return "#/artemis/sendMessage"; }
+ });
+
+ workspace.subLevelTabs.push({
+ content: ' Diagram',
+ title: "View a diagram of the producers, destinations and consumers",
+ isValid: function (workspace) { return workspace.isTopTabActive("artemis") || workspace.selectionHasDomain(artemisJmxDomain); },
+ href: function () { return "#/artemis/diagram"; }
+ });
+});
+
+
+ function isBroker(workspace, domain) {
+ return workspace.hasDomainAndProperties(domain, {'broker': 'Broker'}, 3);
+ }
+
+ function isAddressFolder(workspace, domain) {
+ return workspace.selectionHasDomainAndLastFolderName(domain, 'addresses');
+ }
+
+ function isAddress(workspace, domain) {
+ return workspace.hasDomainAndProperties(domain, {'component': 'addresses'}) && !workspace.hasDomainAndProperties(domain, {'subcomponent': 'queues'});
+ }
+
+ function isQueue(workspace, domain) {
+ return workspace.hasDomainAndProperties(domain, {'subcomponent': 'queues'});
+ }
+
+ return ARTEMIS;
+}(ARTEMIS || {}));
+
+// Very important! Add our module to hawtioPluginLoader so it
+// bootstraps our module
+hawtioPluginLoader.addModule(ARTEMIS.pluginName);
\ No newline at end of file
diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisService.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisService.js
new file mode 100644
index 0000000000..3d7aa559a0
--- /dev/null
+++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/artemisService.js
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * @module ARTEMIS
+ */
+var ARTEMIS = (function(ARTEMIS) {
+
+ ARTEMIS.SERVER = 'Server Messages';
+
+
+ // The ARTEMIS service handles the connection to
+ // the Artemis Jolokia server in the background
+ ARTEMIS.module.factory("ARTEMISService", function(jolokia, $rootScope) {
+ var self = {
+ artemisConsole: undefined,
+
+ getVersion: function(jolokia) {
+ ARTEMIS.log.info("Connecting to ARTEMIS service: " + self.artemisConsole.getServerAttributes(jolokia));
+ } ,
+ initArtemis: function(broker) {
+ ARTEMIS.log.info("*************creating Artemis Console************");
+ self.artemisConsole = new ArtemisConsole();
+ }
+ };
+
+ return self;
+ });
+
+ return ARTEMIS;
+}(ARTEMIS || {}));
diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/brokerDiagram.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/brokerDiagram.js
new file mode 100644
index 0000000000..3faa0939ac
--- /dev/null
+++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/brokerDiagram.js
@@ -0,0 +1,665 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * @module ARTEMIS
+ */
+var ARTEMIS = (function(ARTEMIS) {
+ ARTEMIS.BrokerDiagramController = function ($scope, $compile, $location, localStorage, ARTEMISService, jolokia, workspace, $routeParams) {
+
+ Fabric.initScope($scope, $location, jolokia, workspace);
+ var artemisJmxDomain = localStorage['artemisJmxDomain'] || "org.apache.activemq.artemis";
+
+ $scope.selectedNode = null;
+ var defaultFlags = {
+ panel: true,
+ popup: false,
+ label: true,
+ group: false,
+ profile: false,
+ slave: false,
+ broker: true,
+ network: true,
+ container: false,
+ address: true,
+ queue: true,
+ consumer: true,
+ producer: true
+ };
+ $scope.viewSettings = {};
+ $scope.shapeSize = {
+ broker: 20,
+ queue: 14,
+ address: 14
+ };
+ var redrawGraph = Core.throttled(doRedrawGraph, 1000);
+ var graphBuilder = new ForceGraph.GraphBuilder();
+ Core.bindModelToSearchParam($scope, $location, "searchFilter", "q", "");
+ angular.forEach(defaultFlags, function (defaultValue, key) {
+ var modelName = "viewSettings." + key;
+ // bind model values to search params...
+ function currentValue() {
+ var answer = $location.search()[paramName] || defaultValue;
+ return answer === "false" ? false : answer;
+ }
+
+ var paramName = key;
+ var value = currentValue();
+ Core.pathSet($scope, modelName, value);
+ $scope.$watch(modelName, function () {
+ var current = Core.pathGet($scope, modelName);
+ var old = currentValue();
+ if (current !== old) {
+ var defaultValue = defaultFlags[key];
+ if (current !== defaultValue) {
+ if (!current) {
+ current = "false";
+ }
+ $location.search(paramName, current);
+ }
+ else {
+ $location.search(paramName, null);
+ }
+ }
+ redrawGraph();
+ });
+ });
+ $scope.connectToBroker = function () {
+ var selectedNode = $scope.selectedNode;
+ if (selectedNode) {
+ var container = selectedNode["brokerContainer"] || selectedNode;
+ connectToBroker(container, selectedNode["brokerName"]);
+ }
+ };
+ function connectToBroker(container, brokerName, postfix) {
+ if (postfix === void 0) {
+ postfix = null;
+ }
+
+ var view = "/jmx/attributes?tab=artemis";
+ if (!postfix) {
+ if (brokerName) {
+ // lets default to the broker view
+ postfix = "nid=root-" + artemisJmxDomain + "-Broker-" + brokerName;
+ }
+ }
+ if (postfix) {
+ view += "&" + postfix;
+ }
+ var path = Core.url("/#" + view);
+ window.open(path, '_destination');
+ window.focus();
+ }
+
+ $scope.connectToDestination = function () {
+ var selectedNode = $scope.selectedNode;
+ if (selectedNode) {
+ var container = selectedNode["brokerContainer"] || selectedNode;
+ var brokerName = selectedNode["brokerName"];
+ var destinationType = selectedNode["destinationType"] || selectedNode["typeLabel"];
+ var destinationName = selectedNode["destinationName"];
+ var postfix = null;
+ if (brokerName && destinationType && destinationName) {
+ postfix = "nid=root-" + artemisJmxDomain + "-Broker-" + brokerName + "-" + destinationType + "-" + destinationName;
+ }
+ connectToBroker(container, brokerName, postfix);
+ }
+ };
+ $scope.$on('$destroy', function (event) {
+ stopOldJolokia();
+ });
+ function stopOldJolokia() {
+ var oldJolokia = $scope.selectedNodeJolokia;
+ if (oldJolokia && oldJolokia !== jolokia) {
+ oldJolokia.stop();
+ }
+ }
+
+ $scope.$watch("selectedNode", function (newValue, oldValue) {
+ // lets cancel any previously registered thingy
+ if ($scope.unregisterFn) {
+ $scope.unregisterFn();
+ $scope.unregisterFn = null;
+ }
+ var node = $scope.selectedNode;
+ if (node) {
+ var mbean = node.objectName;
+ var brokerContainer = node.brokerContainer || {};
+ var nodeJolokia = node.jolokia || brokerContainer.jolokia || jolokia;
+ if (nodeJolokia !== $scope.selectedNodeJolokia) {
+ stopOldJolokia();
+ $scope.selectedNodeJolokia = nodeJolokia;
+ if (nodeJolokia !== jolokia) {
+ var rate = Core.parseIntValue(localStorage['updateRate'] || "2000", "update rate");
+ if (rate) {
+ nodeJolokia.start(rate);
+ }
+ }
+ }
+ var dummyResponse = {value: node.panelProperties || {}};
+ if (mbean && nodeJolokia) {
+ ARTEMIS.log.debug("reading ", mbean, " on remote container");
+ $scope.unregisterFn = Core.register(nodeJolokia, $scope, {
+ type: 'read',
+ mbean: mbean
+ }, onSuccess(renderNodeAttributes, {
+ error: function (response) {
+ // probably we've got a wrong mbean name?
+ // so lets render at least
+ renderNodeAttributes(dummyResponse);
+ Core.defaultJolokiaErrorHandler(response);
+ }
+ }));
+ }
+ else {
+ ARTEMIS.log.debug("no mbean or jolokia available, using dummy response");
+ renderNodeAttributes(dummyResponse);
+ }
+ }
+ });
+ function getDestinationTypeName(attributes) {
+ var prefix = attributes["DestinationTemporary"] ? "Temporary " : "";
+ return prefix + (attributes["DestinationTopic"] ? "Topic" : "Queue");
+ }
+
+ var ignoreNodeAttributes = ["Broker", "BrokerId", "BrokerName", "Connection", "DestinationName", "DestinationQueue", "DestinationTemporary", "DestinationTopic",];
+ var ignoreNodeAttributesByType = {
+ producer: ["Producer", "ProducerId"],
+ queue: ["Name", "MessageGroups", "MessageGroupType", "Subscriptions"],
+ topic: ["Name", "Subscriptions"],
+ broker: ["DataDirectory", "DurableTopicSubscriptions", "DynamicDestinationProducers", "InactiveDurableToppicSubscribers"]
+ };
+ var brokerShowProperties = ["Version", "Started"];
+ var onlyShowAttributesByType = {
+ broker: brokerShowProperties,
+ brokerSlave: brokerShowProperties
+ };
+
+ function renderNodeAttributes(response) {
+ var properties = [];
+ if (response) {
+ var value = response.value || {};
+ $scope.selectedNodeAttributes = value;
+ var selectedNode = $scope.selectedNode || {};
+ var brokerContainer = selectedNode['brokerContainer'] || {};
+ var nodeType = selectedNode["type"];
+ var brokerName = selectedNode["brokerName"];
+ var containerId = selectedNode["container"] || brokerContainer["container"];
+ var group = selectedNode["group"] || brokerContainer["group"];
+ var jolokiaUrl = selectedNode["jolokiaUrl"] || brokerContainer["jolokiaUrl"];
+ var profile = selectedNode["profile"] || brokerContainer["profile"];
+ var version = selectedNode["version"] || brokerContainer["version"];
+ var isBroker = nodeType && nodeType.startsWith("broker");
+ var ignoreKeys = ignoreNodeAttributes.concat(ignoreNodeAttributesByType[nodeType] || []);
+ var onlyShowKeys = onlyShowAttributesByType[nodeType];
+ angular.forEach(value, function (v, k) {
+ if (onlyShowKeys ? onlyShowKeys.indexOf(k) >= 0 : ignoreKeys.indexOf(k) < 0) {
+ var formattedValue = Core.humanizeValueHtml(v);
+ properties.push({key: Core.humanizeValue(k), value: formattedValue});
+ }
+ });
+ properties = properties.sortBy("key");
+ var brokerProperty = null;
+ if (brokerName) {
+ var brokerHtml = '' + '
+
+
+
+
+
+ No credentials set for endpoint! Please set your username and password in the Preferences page
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ No credentials set for endpoint! Please set your username and password in the Preferences page
+
+
+
+
+ Choose which files to send from the profile configuration:
+ +
+
+
+
+ -
+
- + {{fileName}} + +
' + brokerName + '';
+ if (version && profile) {
+ var brokerLink = Fabric.brokerConfigLink(workspace, jolokia, localStorage, version, profile, brokerName);
+ if (brokerLink) {
+ brokerHtml += ' ';
+ }
+ }
+ var html = $compile(brokerHtml)($scope);
+ brokerProperty = {key: "Broker", value: html};
+ if (!isBroker) {
+ properties.splice(0, 0, brokerProperty);
+ }
+ }
+ if (containerId) {
+ //var containerModel = "selectedNode" + (selectedNode['brokerContainer'] ? ".brokerContainer" : "");
+ properties.splice(0, 0, {
+ key: "Container",
+ value: $compile('')($scope)
+ });
+ }
+ var destinationName = value["DestinationName"] || selectedNode["destinationName"];
+ if (destinationName && (nodeType !== "queue" && nodeType !== "topic")) {
+ var destinationTypeName = getDestinationTypeName(value);
+ var html = createDestinationLink(destinationName, destinationTypeName);
+ properties.splice(0, 0, {key: destinationTypeName, value: html});
+ }
+ var typeLabel = selectedNode["typeLabel"];
+ var name = selectedNode["name"] || selectedNode["id"] || selectedNode['objectName'];
+ if (typeLabel) {
+ var html = name;
+ if (nodeType === "queue" || nodeType === "topic") {
+ html = createDestinationLink(name, nodeType);
+ }
+ var typeProperty = {key: typeLabel, value: html};
+ if (isBroker && brokerProperty) {
+ typeProperty = brokerProperty;
+ }
+ properties.splice(0, 0, typeProperty);
+ }
+ }
+ $scope.selectedNodeProperties = properties;
+ Core.$apply($scope);
+ }
+
+ /**
+ * Generates the HTML for a link to the destination
+ */
+ function createDestinationLink(destinationName, destinationType) {
+ if (destinationType === void 0) {
+ destinationType = "queue";
+ }
+ return $compile('' + destinationName + '')($scope);
+ }
+
+ $scope.$watch("searchFilter", function (newValue, oldValue) {
+ redrawGraph();
+ });
+ // lets just use the current stuff from the workspace
+ $scope.$watch('workspace.tree', function () {
+ redrawGraph();
+ });
+ $scope.$on('jmxTreeUpdated', function () {
+ redrawGraph();
+ });
+
+ function onBrokerData(response) {
+ if (response) {
+ var responseJson = angular.toJson(response.value);
+ if ($scope.responseJson === responseJson) {
+ return;
+ }
+ $scope.responseJson = responseJson;
+ $scope.brokers = response.value;
+ doRedrawGraph();
+ }
+ }
+
+ function redrawLocalBroker() {
+ var container = {
+ jolokia: jolokia
+ };
+ var containerId = "local";
+ $scope.activeContainers = {
+ containerId: container
+ };
+ var brokers = [];
+ jolokia.search(artemisJmxDomain + ":broker=*", onSuccess(function (response) {
+ angular.forEach(response, function (objectName) {
+ var atts = ARTEMISService.artemisConsole.getServerAttributes(jolokia, objectName);
+ var val = atts.value;
+ var details = Core.parseMBean(objectName);
+ if (details) {
+ var properties = details['attributes'];
+ ARTEMIS.log.info("Got broker: " + objectName + " on container: " + containerId + " properties: " + angular.toJson(properties, true));
+ if (properties) {
+ var master = true;
+ var brokerId = properties["broker"] || "unknown";
+ var nodeId = val["NodeID"];
+ var theBroker = {
+ brokerId: brokerId,
+ nodeId: nodeId
+ };
+ brokers.push(theBroker);
+ if ($scope.viewSettings.broker) {
+ var broker = getOrAddBroker(master, brokerId, nodeId, containerId, container, properties);
+ }
+ }
+ }
+ });
+
+ redrawActiveContainers(brokers);
+ }));
+ }
+
+ function redrawActiveContainers(brokers) {
+ // TODO delete any nodes from dead containers in containersToDelete
+ angular.forEach($scope.activeContainers, function (container, id) {
+ var containerJolokia = container.jolokia;
+ if (containerJolokia) {
+ onContainerJolokia(containerJolokia, container, id, brokers);
+ }
+ else {
+ Fabric.containerJolokia(jolokia, id, function (containerJolokia) {
+ return onContainerJolokia(containerJolokia, container, id, brokers);
+ });
+ }
+ });
+ $scope.graph = graphBuilder.buildGraph();
+ Core.$apply($scope);
+ }
+
+ function doRedrawGraph() {
+ graphBuilder = new ForceGraph.GraphBuilder();
+ redrawLocalBroker();
+ }
+
+ function brokerNameMarkup(brokerName) {
+ return brokerName ? "broker: " + brokerName + "" : "";
+ }
+
+ function onContainerJolokia(containerJolokia, container, id, brokers) {
+ function createQueues(brokers) {
+ if ($scope.viewSettings.queue) {
+ containerJolokia.search(artemisJmxDomain + ":*,subcomponent=queues", onSuccess(function (response) {
+ angular.forEach(response, function (objectName) {
+ var details = Core.parseMBean(objectName);
+ if (details) {
+ var properties = details['attributes'];
+ if (properties) {
+ configureDestinationProperties(properties);
+ var brokerName = properties.broker;
+ var addressName = properties.address;
+ var typeName = "queue";
+ var queueName = properties.queue;
+ var routingType = properties["routing-type"];
+ var destination = getOrAddQueue(properties, typeName, routingType, queueName, addressName, brokerName);
+ }
+ }
+ });
+ graphModelUpdated();
+ createConsumersAndNetwork(brokers);
+ }));
+ } else {
+ createConsumersAndNetwork(brokers);
+ }
+ }
+
+ function createAddresses(brokers) {
+ if ($scope.viewSettings.address) {
+ containerJolokia.search(artemisJmxDomain + ":*,component=addresses", onSuccess(function (response) {
+ angular.forEach(response, function (objectName) {
+ var details = Core.parseMBean(objectName);
+ if (details) {
+ var properties = details['attributes'];
+ if (properties) {
+ var brokerName = properties.broker;
+ var typeName = "address";
+ var addressName = properties.address;
+ var destination = getOrAddAddress(properties, typeName, addressName, brokerName);
+ }
+ }
+ });
+ createQueues(brokers);
+ graphModelUpdated();
+ }));
+ } else {
+ createQueues(brokers);
+ }
+ }
+
+ function createConsumersAndNetwork(brokers) {
+ angular.forEach(brokers, function (broker) {
+ mBean = artemisJmxDomain + ":broker=" + broker.brokerId;
+ // find consumers
+ if ($scope.viewSettings.consumer) {
+ ARTEMISService.artemisConsole.getConsumers(mBean, containerJolokia, onSuccess(function (properties) {
+ consumers = properties.value;
+ ARTEMIS.log.info(consumers);
+ angular.forEach(angular.fromJson(consumers), function (consumer) {
+ if (consumer) {
+
+ configureDestinationProperties(consumer);
+ var consumerId = consumer.sessionID + "-" + consumer.consumerID;
+ if (consumerId) {
+ var queueName = consumer.queueName;
+ var consumerNode = getOrAddNode("consumer", consumerId, consumer, function () {
+ return {
+ typeLabel: "Consumer",
+ brokerContainer: container,
+ //objectName: "null",
+ jolokia: containerJolokia,
+ popup: {
+ title: "Consumer: " + consumerId,
+ content: "client: " + (consumer.connectionID || "") + "
" + brokerNameMarkup(broker.brokerId) + } + }; + }); + addLinkIds("queue:\"" + queueName + "\"", consumerNode["id"], "consumer"); + } + } + }); + graphModelUpdated(); + })); + } + + + // find networks of brokers + if ($scope.viewSettings.network && $scope.viewSettings.broker) { + + ARTEMISService.artemisConsole.getRemoteBrokers(mBean, containerJolokia, onSuccess(function (properties) { + remoteBrokers = properties.value; + + ARTEMIS.log.info("remoteBrokers=" + angular.toJson(remoteBrokers)) + angular.forEach(angular.fromJson(remoteBrokers), function (remoteBroker) { + if (remoteBroker) { + ARTEMIS.log.info("remote=" + angular.toJson(remoteBroker)) + if (broker.nodeId != remoteBroker.nodeID) { + getOrAddBroker(true, "\"" + remoteBroker.live + "\"", remoteBroker.nodeID, "remote", null, properties); + addLinkIds("broker:" + broker.brokerId, "broker:" + "\"" + remoteBroker.live + "\"", "network"); + + var backup = remoteBroker.backup; + if (backup) { + getOrAddBroker(false, "\"" + backup + "\"", remoteBroker.nodeID, "remote", null, properties); + addLinkIds("broker:" + "\"" + remoteBroker.live + "\"", "broker:" + "\"" + backup + "\"", "network"); + } + } + else { + var backup = remoteBroker.backup; + if (backup) { + getOrAddBroker(false, "\"" + remoteBroker.backup + "\"", remoteBroker.nodeID, "remote", null, properties); + addLinkIds("broker:" + broker.brokerId, "broker:" + "\"" + remoteBroker.backup + "\"", "network"); + } + } + } + }); + graphModelUpdated(); + })); + } + }); + } + + if (containerJolokia) { + container.jolokia = containerJolokia; + function getOrAddQueue(properties, typeName, routingType, queueName, addressName, brokerName) { + var queue = getOrAddNode(typeName.toLowerCase(), queueName, properties, function () { + var objectName = ""; + if (addressName) { + objectName = artemisJmxDomain + ":broker=" + brokerName + ",component=addresses,address=" + addressName + ",subcomponent=queues,routing-type=" + routingType + ",queue=" + queueName; + + } + ARTEMIS.log.info(objectName); + var answer = { + typeLabel: typeName, + brokerContainer: container, + objectName: objectName, + jolokia: containerJolokia, + popup: { + title: "queue: " + queueName, + content: "address:" + addressName + } + }; + if (!addressName) { + containerJolokia.search(artemisJmxDomain + ":broker=" + brokerName + ",component=addresses,address=" + addressName + ",subcomponent=queues,routing-type=" + routingType + ",queue=" + queueName + ",*", onSuccess(function (response) { + if (response && response.length) { + answer.objectName = response[0]; + } + })); + } + return answer; + }); + if (queue && $scope.viewSettings.broker && addressName) { + addLinkIds("address:" + addressName, queue["id"], "queue"); + } + return queue; + } + + function getOrAddAddress(properties, typeName, destinationName, brokerName) { + var destination = getOrAddNode(typeName.toLowerCase(), destinationName, properties, function () { + var objectName = ""; + if (brokerName) { + objectName = artemisJmxDomain + ":broker=" + brokerName + ",component=addresses,address=" + destinationName; + } + var answer = { + typeLabel: typeName, + brokerContainer: container, + objectName: objectName, + jolokia: containerJolokia, + popup: { + title: typeName + ": " + destinationName, + content: brokerNameMarkup(brokerName) + } + }; + if (!brokerName) { + containerJolokia.search(artemisJmxDomain + ":broker=" + brokerName + ",component=addresses,address=" + destinationName + ",*", onSuccess(function (response) { + if (response && response.length) { + answer.objectName = response[0]; + } + })); + } + return answer; + }); + if (destination && $scope.viewSettings.broker && brokerName) { + addLinkIds(brokerNodeId(brokerName), destination["id"], "address"); + } + return destination; + } + + createAddresses(brokers); + } + } + + function graphModelUpdated() { + $scope.graph = graphBuilder.buildGraph(); + Core.$apply($scope); + } + + function getOrAddBroker(master, brokerId, nodeId, containerId, container, brokerStatus) { + var broker = null; + var brokerFlag = master ? $scope.viewSettings.broker : $scope.viewSettings.slave; + if (brokerFlag) { + broker = getOrAddNode("broker", brokerId, brokerStatus, function () { + return { + type: master ? "broker" : "brokerSlave", + typeLabel: master ? "Broker" : "Slave Broker", + popup: { + title: (master ? "Master" : "Slave") + " Broker: " + brokerId, + content: "Container: " + containerId + "
Node ID: " + nodeId + } + }; + }); + if (!broker['objectName']) { + // lets try guess the mbean name + broker['objectName'] = artemisJmxDomain + ":broker=" + brokerId; + ARTEMIS.log.debug("Guessed broker mbean: " + broker['objectName']); + } + if (!broker['brokerContainer'] && container) { + broker['brokerContainer'] = container; + } + if (!broker['nodeID']) { + broker['nodeID'] = nodeId; + } + } + return broker; + } + + function getOrAddNode(typeName, id, properties, createFn) { + var node = null; + if (id) { + var nodeId = typeName + ":" + id; + node = graphBuilder.getNode(nodeId); + if (!node) { + var nodeValues = createFn(); + node = angular.copy(properties); + + angular.forEach(nodeValues, function (value, key) { + return node[key] = value; + }); + node['id'] = nodeId; + if (!node['type']) { + node['type'] = typeName; + } + if (!node['name']) { + node['name'] = id; + } + if (node) { + var size = $scope.shapeSize[typeName]; + if (size && !node['size']) { + node['size'] = size; + } + if (!node['summary']) { + node['summary'] = node['popup'] || ""; + } + if (!$scope.viewSettings.popup) { + delete node['popup']; + } + if (!$scope.viewSettings.label) { + delete node['name']; + } + // lets not add nodes which are defined as being disabled + var enabled = $scope.viewSettings[typeName]; + if (enabled || !angular.isDefined(enabled)) { + graphBuilder.addNode(node); + } + else { + } + } + } + } + return node; + } + + function addLink(object1, object2, linkType) { + if (object1 && object2) { + addLinkIds(object1.id, object2.id, linkType); + } + } + + function addLinkIds(id1, id2, linkType) { + ARTEMIS.log.info("adding " + id1 + " to " + id2 + " " + linkType) + if (id1 && id2) { + graphBuilder.addLink(id1, id2, linkType); + } + } + + function brokerNodeId(brokerId) { + return brokerId ? "broker:" + brokerId : null; + } + + /** + * Avoid the JMX type property clashing with the ForceGraph type property; used for associating css classes with nodes on the graph + * + * @param properties + */ + function renameTypeProperty(properties) { + properties.mbeanType = properties['type']; + delete properties['type']; + } + + function configureDestinationProperties(properties) { + renameTypeProperty(properties); + var destinationType = properties.destinationType || "Queue"; + var typeName = destinationType.toLowerCase(); + properties.isQueue = !typeName.startsWith("t"); + properties['destType'] = typeName; + } + }; + + return ARTEMIS; +} (ARTEMIS || {})); \ No newline at end of file diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/browse.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/browse.js new file mode 100644 index 0000000000..9ced888ec0 --- /dev/null +++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/browse.js @@ -0,0 +1,499 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/** + * @module ARTEMIS + */ +var ARTEMIS = (function(ARTEMIS) { + + ARTEMIS.BrowseQueueController = function ($scope, workspace, ARTEMISService, jolokia, localStorage, artemisMessage, $location, $timeout) { + $scope.searchText = ''; + $scope.allMessages = []; + $scope.messages = []; + $scope.headers = {}; + $scope.mode = 'text'; + $scope.deleteDialog = false; + $scope.moveDialog = false; + $scope.gridOptions = { + selectedItems: [], + data: 'messages', + displayFooter: false, + showFilter: false, + showColumnMenu: true, + enableColumnResize: true, + enableColumnReordering: true, + enableHighlighting: true, + filterOptions: { + filterText: '', + useExternalFilter: true + }, + selectWithCheckboxOnly: true, + showSelectionCheckbox: true, + maintainColumnRatios: false, + columnDefs: [ + { + field: 'messageID', + displayName: 'Message ID', + cellTemplate: '', + // for ng-grid + width: '10%' + }, + { + field: 'userID', + displayName: 'User ID', + width: '10%' + }, + { + field: 'type', + displayName: 'Type', + width: '10%' + }, + { + field: 'durable', + displayName: 'Durable', + width: '10%' + }, + { + field: 'priority', + displayName: 'Priority', + width: '7%' + }, + { + field: 'timestamp', + displayName: 'Timestamp', + width: '19%' + }, + { + field: 'expiration', + displayName: 'Expires', + width: '10%' + }, + { + field: 'redelivered', + displayName: 'Redelivered', + width: '10%' + } + ], + afterSelectionChange: afterSelectionChange + }; + $scope.showMessageDetails = false; + var ignoreColumns = ["PropertiesText", "BodyPreview", "text"]; + var flattenColumns = ["BooleanProperties", "ByteProperties", "ShortProperties", "IntProperties", "LongProperties", "FloatProperties", "DoubleProperties", "StringProperties"]; + $scope.$watch('workspace.selection', function () { + if (workspace.moveIfViewInvalid()) { + return; + } + // lets defer execution as we may not have the selection just yet + setTimeout(loadTable, 50); + }); + $scope.$watch('gridOptions.filterOptions.filterText', function (filterText) { + filterMessages(filterText); + }); + $scope.openMessageDialog = function (message) { + ARTEMIS.selectCurrentMessage(message, "messageID", $scope); + if ($scope.row) { + $scope.mode = CodeEditor.detectTextFormat($scope.row.Text); + $scope.showMessageDetails = true; + } + }; + $scope.refresh = loadTable; + ARTEMIS.decorate($scope); + $scope.moveMessages = function () { + var selection = workspace.selection; + var mbean = selection.objectName; + if (mbean && selection) { + var selectedItems = $scope.gridOptions.selectedItems; + $scope.message = "Moved " + Core.maybePlural(selectedItems.length, "message" + " to " + $scope.queueName); + var operation = "moveMessageTo(java.lang.String, java.lang.String)"; + angular.forEach(selectedItems, function (item, idx) { + var id = item.messageID; + if (id) { + var callback = (idx + 1 < selectedItems.length) ? intermediateResult : moveSuccess; + jolokia.execute(mbean, operation, id, $scope.queueName, onSuccess(callback)); + ARTEMISService.artemisConsole.moveMessage(mbean, jolokia, id, $scope.queueName, onSuccess(callback)); + } + }); + } + }; + $scope.resendMessage = function () { + var selection = workspace.selection; + var mbean = selection.objectName; + if (mbean && selection) { + var selectedItems = $scope.gridOptions.selectedItems; + //always assume a single message + artemisMessage.message = selectedItems[0]; + $location.path('artemis/sendMessage'); + } + }; + $scope.deleteMessages = function () { + var selection = workspace.selection; + var mbean = selection.objectName; + if (mbean && selection) { + var selectedItems = $scope.gridOptions.selectedItems; + $scope.message = "Deleted " + Core.maybePlural(selectedItems.length, "message"); + angular.forEach(selectedItems, function (item, idx) { + var id = item.messageID; + if (id) { + var callback = (idx + 1 < selectedItems.length) ? intermediateResult : operationSuccess; + ARTEMISService.artemisConsole.deleteMessage(mbean, jolokia, id, onSuccess(callback)); + } + }); + } + }; + $scope.retryMessages = function () { + var selection = workspace.selection; + var mbean = selection.objectName; + if (mbean && selection) { + var selectedItems = $scope.gridOptions.selectedItems; + $scope.message = "Retry " + Core.maybePlural(selectedItems.length, "message"); + var operation = "retryMessage(java.lang.String)"; + angular.forEach(selectedItems, function (item, idx) { + var id = item.messageID; + if (id) { + var callback = (idx + 1 < selectedItems.length) ? intermediateResult : operationSuccess; + jolokia.execute(mbean, operation, id, onSuccess(callback)); + ARTEMISService.artemisConsole.retryMessage(mbean, jolokia, id, onSuccess(callback)); + } + }); + } + }; + $scope.queueNames = function (completionText) { + var queuesFolder = ARTEMIS.getSelectionQueuesFolder(workspace); + if (queuesFolder) { + var selectedQueue = workspace.selection.key; + var otherQueues = queuesFolder.children.exclude(function (child) { + return child.key == selectedQueue; + }); + return (otherQueues) ? otherQueues.map(function (n) { + return n.title; + }) : []; + } + else { + return []; + } + }; + function populateTable(response) { + var data = response.value; + ARTEMIS.log.info("loading data:" + data); + + if (!angular.isArray(data)) { + $scope.allMessages = []; + angular.forEach(data, function (value, idx) { + $scope.allMessages.push(value); + }); + } + else { + $scope.allMessages = data; + } + angular.forEach($scope.allMessages, function (message) { + message.headerHtml = createHeaderHtml(message); + message.bodyText = createBodyText(message); + }); + filterMessages($scope.gridOptions.filterOptions.filterText); + Core.$apply($scope); + } + + /* + * For some reason using ng-repeat in the modal dialog doesn't work so lets + * just create the HTML in code :) + */ + function createBodyText(message) { + + ARTEMIS.log.info("loading message:" + message); + if (message.text) { + var body = message.text; + var lenTxt = "" + body.length; + message.textMode = "text (" + lenTxt + " chars)"; + return body; + } + else if (message.BodyPreview) { + var code = Core.parseIntValue(localStorage["ARTEMISBrowseBytesMessages"] || "1", "browse bytes messages"); + var body; + message.textMode = "bytes (turned off)"; + if (code != 99) { + var bytesArr = []; + var textArr = []; + message.BodyPreview.forEach(function (b) { + if (code === 1 || code === 2) { + // text + textArr.push(String.fromCharCode(b)); + } + if (code === 1 || code === 4) { + // hex and must be 2 digit so they space out evenly + var s = b.toString(16); + if (s.length === 1) { + s = "0" + s; + } + bytesArr.push(s); + } + else { + // just show as is without spacing out, as that is usually more used for hex than decimal + var s = b.toString(10); + bytesArr.push(s); + } + }); + var bytesData = bytesArr.join(" "); + var textData = textArr.join(""); + if (code === 1 || code === 2) { + // bytes and text + var len = message.BodyPreview.length; + var lenTxt = "" + textArr.length; + body = "bytes:\n" + bytesData + "\n\ntext:\n" + textData; + message.textMode = "bytes (" + len + " bytes) and text (" + lenTxt + " chars)"; + } + else { + // bytes only + var len = message.BodyPreview.length; + body = bytesData; + message.textMode = "bytes (" + len + " bytes)"; + } + } + return body; + } + else { + message.textMode = "unsupported"; + return "Unsupported message body type which cannot be displayed by hawtio"; + } + } + + /* + * For some reason using ng-repeat in the modal dialog doesn't work so lets + * just create the HTML in code :) + */ + function createHeaderHtml(message) { + var headers = createHeaders(message); + var properties = createProperties(message); + var headerKeys = Object.extended(headers).keys(); + + function sort(a, b) { + if (a > b) + return 1; + if (a < b) + return -1; + return 0; + } + + var propertiesKeys = Object.extended(properties).keys().sort(sort); + var jmsHeaders = headerKeys.filter(function (key) { + return key.startsWith("JMS"); + }).sort(sort); + var remaining = headerKeys.subtract(jmsHeaders, propertiesKeys).sort(sort); + var buffer = []; + + function appendHeader(key) { + var value = headers[key]; + if (value === null) { + value = ''; + } + buffer.push('