You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ea...@apache.org on 2019/11/16 22:27:44 UTC
[qpid-dispatch] branch eallen-DISPATCH-1385 updated: Added more
tests
This is an automated email from the ASF dual-hosted git repository.
eallen pushed a commit to branch eallen-DISPATCH-1385
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/eallen-DISPATCH-1385 by this push:
new a154c68 Added more tests
a154c68 is described below
commit a154c68dddb5ac101a36921085006bbc47233c13
Author: Ernest Allen <ea...@redhat.com>
AuthorDate: Sat Nov 16 17:27:30 2019 -0500
Added more tests
---
console/react/.prettierrc | 2 +-
console/react/package.json | 2 +
console/react/src/App.test.js | 20 +-
console/react/src/chord/chordToolbar.test.js | 31 +-
console/react/src/chord/chordViewer.js | 99 +-
console/react/src/chord/chordViewer.test.js | 35 +-
console/react/src/chord/data.js | 35 +-
console/react/src/chord/matrix.js | 142 +-
console/react/src/connect-form.js | 67 +-
console/react/src/connectPage.js | 34 +-
console/react/src/details/schema/schemaPage.js | 31 +-
.../react/src/details/schema/schemaPage.test.js | 16 +-
console/react/src/layout.js | 105 +-
.../react/src/overview/dashboard/dashboardPage.js | 23 +-
.../overview/dashboard/delayedDeliveriesCard.js | 42 +-
console/react/src/qdrService.mock.js | 2128 +----------
console/react/src/topology/clientInfoComponent.js | 80 +-
.../src/topology/clientInfoDetailsComponent.jsx | 11 +-
console/react/src/topology/map.js | 50 +-
console/react/src/topology/nodes.js | 48 +-
console/react/src/topology/svgUtils.js | 15 +-
console/react/src/topology/topologyPage.js | 6 +-
console/react/src/topology/topologyPage.test.js | 14 +
console/react/src/topology/topologyViewer.js | 162 +-
console/react/src/topology/topologyViewer.test.js | 51 +-
console/react/test_data/fetchEntities.js | 3836 ++++++++++++++++++++
console/react/test_data/nodeInfo.js | 206 ++
console/react/test_data/schema.js | 1922 ++++++++++
console/react/yarn.lock | 78 +-
29 files changed, 6473 insertions(+), 2818 deletions(-)
diff --git a/console/react/.prettierrc b/console/react/.prettierrc
index a6058bb..b17e41b 100644
--- a/console/react/.prettierrc
+++ b/console/react/.prettierrc
@@ -1,6 +1,6 @@
{
"singleQuote": false,
- "printWidth": 120,
+ "printWidth": 90,
"semi": true,
"useTabs": false,
"arrowParens": "avoid"
diff --git a/console/react/package.json b/console/react/package.json
index 0c95076..74802e8 100644
--- a/console/react/package.json
+++ b/console/react/package.json
@@ -10,12 +10,14 @@
"@patternfly/react-styles": "^3.3.3",
"@patternfly/react-table": "^2.11.1",
"@patternfly/react-topology": "^2.7.31",
+ "@react-mock/localstorage": "^0.1.2",
"@testing-library/jest-dom": "^4.2.3",
"@testing-library/react": "^9.3.2",
"body-parser": "^1.19.0",
"d3-queue": "^3.0.7",
"eslint-plugin-patternfly-react": "^0.2.3",
"express": "^4.17.1",
+ "jest-axe": "^3.2.0",
"lodash-es": "^4.17.11",
"patternfly-react": "^2.36.1",
"prettier": "^1.18.2",
diff --git a/console/react/src/App.test.js b/console/react/src/App.test.js
index b2ed536..18c16e5 100644
--- a/console/react/src/App.test.js
+++ b/console/react/src/App.test.js
@@ -1,14 +1,18 @@
import React from "react";
-import { render } from '@testing-library/react';
+import { render } from "@testing-library/react";
+import { axe, toHaveNoViolations } from "jest-axe";
+
import App from "./App";
-const title = "Apache Qpid Dispatch Console"
+expect.extend(toHaveNoViolations);
+
+const title = "Apache Qpid Dispatch Console";
const config = { title };
-it("renders without crashing", () => {
- render(<App config={config} />);
-});
+it("renders the correct title without accessibility violations", async () => {
+ const { container, getAllByText } = render(<App config={config} />);
+
+ const results = await axe(container);
+ expect(results).toHaveNoViolations();
-it('renders the correct title', () => {
- const { getAllByText } = render(<App config={config} />);
expect(getAllByText(title));
-});
\ No newline at end of file
+});
diff --git a/console/react/src/chord/chordToolbar.test.js b/console/react/src/chord/chordToolbar.test.js
index 2b01a42..bb53359 100644
--- a/console/react/src/chord/chordToolbar.test.js
+++ b/console/react/src/chord/chordToolbar.test.js
@@ -1,32 +1,28 @@
import React from "react";
-import { render, fireEvent } from '@testing-library/react';
+import { render, fireEvent } from "@testing-library/react";
import ChordToolbar from "./chordToolbar";
-it('renders a ChordToolbar', () => {
- const routerName = "testRouterName"
+it("renders a ChordToolbar", () => {
+ const routerName = "testRouterName";
const props = {
isRate: true,
byAddress: true,
- handleAddNotification: () => { },
- handleChangeOption: () => { },
+ handleAddNotification: () => {},
+ handleChangeOption: () => {},
addresses: { testAddress: true },
chordColors: { testAddress: "#EAEAEA" },
arcColors: { testRouterName: "#EBAEBA" },
- handleChangeAddress: () => handleChangeAddressCalled = true,
- handleHoverAddress: (address, over) => handleHoverAddress = over,
- handleHoverRouter: () => { }
- }
- const {
- getByLabelText,
- getByText,
- getByTestId
- } = render(<ChordToolbar {...props} />);
+ handleChangeAddress: () => {},
+ handleHoverAddress: () => {},
+ handleHoverRouter: () => {}
+ };
+ const { getByLabelText, getByText, getByTestId } = render(<ChordToolbar {...props} />);
// the toolbar should be present
expect(getByTestId("chord-toolbar")).toBeInTheDocument();
// the options drowdown button should be present
- const optionsButton = getByLabelText('button-for-Options');
+ const optionsButton = getByLabelText("button-for-Options");
expect(optionsButton).toBeInTheDocument();
fireEvent.click(optionsButton);
@@ -37,11 +33,10 @@ it('renders a ChordToolbar', () => {
expect(getByText("testAddress")).toBeInTheDocument();
// the options drowdown button should be present
- const routersButton = getByLabelText('button-for-Routers');
+ const routersButton = getByLabelText("button-for-Routers");
expect(routersButton).toBeInTheDocument();
fireEvent.click(routersButton);
// clicking on the Routers buttons should show the list of routers
expect(getByText(routerName)).toBeInTheDocument();
-
-})
+});
diff --git a/console/react/src/chord/chordViewer.js b/console/react/src/chord/chordViewer.js
index f3fd40d..b2ad22e 100644
--- a/console/react/src/chord/chordViewer.js
+++ b/console/react/src/chord/chordViewer.js
@@ -19,7 +19,6 @@ under the License.
import React, { Component } from "react";
import { TopologyView, TopologySideBar } from "@patternfly/react-topology";
-import * as d3 from "d3";
import { getSizes } from "../topology/topoUtils";
import { separateAddresses, aggregateAddresses } from "./filters.js";
import { ChordData } from "./data.js";
@@ -27,6 +26,7 @@ import { qdrRibbon } from "./ribbon/ribbon.js";
import { qdrlayoutChord } from "./layout/layout.js";
import ChordToolbar from "./chordToolbar";
import QDRPopup from "../qdrPopup";
+import * as d3 from "d3";
const CHORDOPTIONSKEY = "chordOptions";
const CHORDFILTERKEY = "chordFilter";
@@ -53,23 +53,13 @@ class ChordViewer extends Component {
this.state.legendOptions = savedOptions
? JSON.parse(savedOptions)
: {
- isRate: true,
- byAddress: true,
- optionsOpen: true,
- routersOpen: true,
- addressesOpen: true
- };
- if (typeof this.state.legendOptions.optionsOpen === "undefined") {
- this.state.legendOptions["optionsOpen"] = true;
- this.state.legendOptions["routersOpen"] = true;
- this.state.legendOptions["addressesOpen"] = true;
- }
+ isRate: true,
+ byAddress: true
+ };
this.chordData = new ChordData(
this.props.service,
this.state.legendOptions.isRate,
- this.state.legendOptions.byAddress
- ? separateAddresses
- : aggregateAddresses
+ this.state.legendOptions.byAddress ? separateAddresses : aggregateAddresses
);
this.chordData.setFilter(this.excludedAddresses);
this.chordColors = {};
@@ -139,8 +129,7 @@ class ChordViewer extends Component {
d3.select("#chord svg").remove();
- let xtrans =
- this.outerRadius === MIN_RADIUS ? SMALL_OFFSET : this.outerRadius;
+ let xtrans = this.outerRadius === MIN_RADIUS ? SMALL_OFFSET : this.outerRadius;
this.svg = d3
.select("#chord")
.append("svg")
@@ -199,15 +188,12 @@ class ChordViewer extends Component {
//startOver();
//};
//d3.select(window).on('resize.updatesvg', updateWindow);
- windowResized = () => { };
+ windowResized = () => {};
// size the diagram based on the browser window size
getRadius = () => {
const { width, height } = getSizes(this.chordRef);
- return Math.max(
- Math.floor((Math.min(width, height) * 0.9) / 2),
- MIN_RADIUS
- );
+ return Math.max(Math.floor((Math.min(width, height) * 0.9) / 2), MIN_RADIUS);
};
// diagram sizes that change when browser is resized
@@ -337,11 +323,9 @@ class ChordViewer extends Component {
if (!matrix.aggregate) {
address += "<br/>";
}
- let title =
- address + from + " → " + to + ": " + this.formatNumber(d.source.value);
+ let title = address + from + " → " + to + ": " + this.formatNumber(d.source.value);
if (d.target.value > 0 && to !== from) {
- title +=
- "<br/>" + to + " → " + from + ": " + this.formatNumber(d.target.value);
+ title += "<br/>" + to + " → " + from + ": " + this.formatNumber(d.target.value);
}
return title;
};
@@ -397,9 +381,6 @@ class ChordViewer extends Component {
if (addressLen > 0 && this.excludedAddresses.length === addressLen) {
this.allAddressesFiltered = true;
}
- console.log(
- `doRenderChord allAddressesFiltered ${this.allAddressesFiltered}`
- );
this.noValues = false;
let matrixMessages,
duration = TRANSITION_DURATION;
@@ -410,7 +391,9 @@ class ChordViewer extends Component {
if (!this.theyveBeenWarned) {
this.theyveBeenWarned = true;
let msg = "There is no message traffic";
- if (addressLen !== 0) msg += " for the selected addresses";
+ if (addressLen !== 0) {
+ msg += " for the selected addresses";
+ }
this.setState({ showEmpty: true, emptyText: msg });
}
this.emptyCircle();
@@ -442,7 +425,8 @@ class ChordViewer extends Component {
let newArcs = arcsGroup
.enter()
.append("svg:g")
- .attr("class", "arc");
+ .attr("class", "arc")
+ .attr("aria-label", d => d.key);
// each new arc is an svg:path that has a fixed color
newArcs
@@ -505,7 +489,7 @@ class ChordViewer extends Component {
.transition()
.duration(duration / 2)
.attrTween("d", this.arcTweenExit)
- .each("end", function () {
+ .each("end", function() {
d3.select(this)
.node()
.parentNode.remove();
@@ -513,9 +497,7 @@ class ChordViewer extends Component {
// decorate the chord layout's .chord() data with key, color, and orgIndex
rechord.chordData = this.decorateChordData(rechord, matrix);
- let chordPaths = this.svg
- .selectAll("path.chord")
- .data(rechord.chordData, d => d.key);
+ let chordPaths = this.svg.selectAll("path.chord").data(rechord.chordData, d => d.key);
// new chords are paths
chordPaths
@@ -678,7 +660,7 @@ class ChordViewer extends Component {
});
}
let self = this;
- chords.each(function (d) {
+ chords.each(function(d) {
let chord = d3.select(this);
// This version of d3 doesn't support multiple concurrent transitions on the same selection.
// Since we want to animate the chord's path as well as its color, we create a dummy selection
@@ -725,12 +707,12 @@ class ChordViewer extends Component {
oldChords[d.key] = d;
});
}
- chords.each(function (d) {
+ chords.each(function(d) {
let chord = d3.select(this);
d3.select({})
.transition()
.duration(duration)
- .tween("style:" + style, function () {
+ .tween("style:" + style, function() {
let old = oldChords[d.key],
interpolate;
let oldColor = "#CCCCCC",
@@ -774,24 +756,13 @@ class ChordViewer extends Component {
let same = start === angle(d);
let tsame = startTranslate === this.textRadius;
- let transTween = d3.interpolateNumber(
- startTranslate,
- this.textRadius + 10
- );
+ let transTween = d3.interpolateNumber(startTranslate, this.textRadius + 10);
return t => {
let rot = same ? start : tween(t);
if (isNaN(rot)) rot = 0;
let tra = tsame ? this.textRadius + 10 : transTween(t);
- return (
- "rotate(" +
- ((rot * 180) / Math.PI - 90) +
- ") " +
- "translate(" +
- tra +
- ",0)" +
- orient
- );
+ return `rotate(${(rot * 180) / Math.PI - 90}) translate(${tra},0) ${orient}`;
};
};
};
@@ -831,7 +802,7 @@ class ChordViewer extends Component {
updateNow = () => {
clearInterval(this.interval);
- this.chordData.getMatrix().then(this.renderChord, function (e) {
+ this.chordData.getMatrix().then(this.renderChord, function(e) {
console.log(ERROR_RENDERING + e);
});
this.interval = setInterval(this.doUpdate, TRANSITION_DURATION);
@@ -859,9 +830,7 @@ class ChordViewer extends Component {
} else {
d3.select("#legend").classed("byAddress", checked);
this.chordData.setConverter(
- this.state.legendOptions.byAddress
- ? separateAddresses
- : aggregateAddresses
+ this.state.legendOptions.byAddress ? separateAddresses : aggregateAddresses
);
this.switchedByAddress = true;
}
@@ -879,8 +848,7 @@ class ChordViewer extends Component {
this.excludedAddresses = [];
for (let address in this.state.addresses) {
- if (!this.state.addresses[address])
- this.excludedAddresses.push(address);
+ if (!this.state.addresses[address]) this.excludedAddresses.push(address);
}
localStorage[CHORDFILTERKEY] = JSON.stringify(this.excludedAddresses);
if (this.chordData) this.chordData.setFilter(this.excludedAddresses);
@@ -916,8 +884,7 @@ class ChordViewer extends Component {
d3.selectAll("path.chord").classed(
"fade",
p =>
- indexes.indexOf(p.source.orgindex) < 0 &&
- indexes.indexOf(p.target.orgindex) < 0
+ indexes.indexOf(p.source.orgindex) < 0 && indexes.indexOf(p.target.orgindex) < 0
);
};
@@ -936,8 +903,7 @@ class ChordViewer extends Component {
d3.selectAll("path.chord").classed(
"fade",
p =>
- indexes.indexOf(p.source.orgindex) < 0 &&
- indexes.indexOf(p.target.orgindex) < 0
+ indexes.indexOf(p.source.orgindex) < 0 && indexes.indexOf(p.target.orgindex) < 0
);
};
leaveLegend = () => {
@@ -955,9 +921,6 @@ class ChordViewer extends Component {
handleChangeAddress={this.handleChangeAddress}
handleHoverAddress={this.handleHoverAddress}
handleHoverRouter={this.handleHoverRouter}
- optionsOpen={this.state.legendOptions.optionsOpen}
- routersOpen={this.state.legendOptions.routersOpen}
- addressesOpen={this.state.legendOptions.addressesOpen}
isRate={this.state.legendOptions.isRate}
byAddress={this.state.legendOptions.byAddress}
arcColors={this.arcColors}
@@ -971,10 +934,12 @@ class ChordViewer extends Component {
>
<div ref={el => (this.chordRef = el)} className="qdrChord">
{this.state.showEmpty ? (
- <div aria-label="chord-no-traffic" id="noTraffic">{this.state.emptyText}</div>
+ <div aria-label="chord-no-traffic" id="noTraffic">
+ {this.state.emptyText}
+ </div>
) : (
- <React.Fragment />
- )}
+ <div aria-label="chord-traffic" />
+ )}
<div aria-label="chord-diagram" id="chord"></div>
<div
id="popover-div"
diff --git a/console/react/src/chord/chordViewer.test.js b/console/react/src/chord/chordViewer.test.js
index d494607..76e9265 100644
--- a/console/react/src/chord/chordViewer.test.js
+++ b/console/react/src/chord/chordViewer.test.js
@@ -1,21 +1,40 @@
import React from "react";
-import { render } from '@testing-library/react';
-import ChordViewer from "./chordViewer";
+import { render, fireEvent, waitForElement } from "@testing-library/react";
import { mockService } from "../qdrService.mock";
+import ChordViewer from "./chordViewer";
+import { LocalStorageMock } from "@react-mock/localstorage";
-it("renders the TopologyViewer component", () => {
+it("renders the ChordViewer component", async () => {
const props = {
service: mockService({})
- }
+ };
const { getByLabelText } = render(
- <ChordViewer {...props} />
- )
+ <LocalStorageMock
+ items={{
+ chordOptions: JSON.stringify({
+ isRate: false,
+ byAddress: true
+ })
+ }}
+ >
+ <ChordViewer {...props} />
+ </LocalStorageMock>
+ );
// make sure it rendered the component
const pfTopologyView = getByLabelText("chord-viewer");
expect(pfTopologyView).toBeInTheDocument();
- // make sure it created the svg. Note: this will be the empty circle
- // since there is no traffic
+ // make sure it created the svg
expect(getByLabelText("chord-svg")).toBeInTheDocument();
+
+ const optionsButton = getByLabelText("button-for-Options");
+ fireEvent.click(optionsButton);
+
+ // turn on show by address
+ const addressButton = getByLabelText("show by address");
+ fireEvent.click(addressButton);
+
+ // after 1 update period, the B chord should be in the svg
+ await waitForElement(() => getByLabelText("B"));
});
diff --git a/console/react/src/chord/data.js b/console/react/src/chord/data.js
index 053521c..cdf00d8 100644
--- a/console/react/src/chord/data.js
+++ b/console/react/src/chord/data.js
@@ -105,19 +105,17 @@ class ChordData {
continue;
}
let idIndex = routerNode.attributeNames.indexOf("id");
- // ingressRouters is an array of router names in the same order that the ingressHistogram values will be in
+ // ingressRouters is an array of router names in the same order
+ // that the ingressHistogram values will be in
for (let i = 0; i < routerNode.results.length; i++) {
ingressRouters.push(routerNode.results[i][idIndex]);
}
// the name of the router we are working on
let egressRouter = self.QDRService.utilities.nameFromId(nodeId);
- // loop through the router links for this router looking for out/endpoint/non-console links
+ // loop through the router links for this router looking for
+ // out/endpoint/non-console links
let routerLinks = results[nodeId]["router.link"];
- for (
- let i = 0;
- routerLinks && i < routerLinks.results.length;
- i++
- ) {
+ for (let i = 0; routerLinks && i < routerLinks.results.length; i++) {
let link = self.QDRService.utilities.flatten(
routerLinks.attributeNames,
routerLinks.results[i]
@@ -126,22 +124,19 @@ class ChordData {
if (
link.linkType === "endpoint" &&
link.linkDir === "out" &&
- (link.owningAddr &&
- !link.owningAddr.startsWith("Ltemp.") &&
- !link.owningAddr.startsWith("M0$"))
+ link.owningAddr &&
+ !link.owningAddr.startsWith("Ltemp.") &&
+ !link.owningAddr.startsWith("M0$")
) {
- // keep track of the raw egress values as well as their ingress and egress routers and the address
+ // keep track of the raw egress values as well as their
+ // ingress and egress routers and the address
for (let j = 0; j < ingressRouters.length; j++) {
- let messages = link.ingressHistogram
- ? link.ingressHistogram[j]
- : 0;
+ let messages = link.ingressHistogram ? link.ingressHistogram[j] : 0;
if (messages) {
values.push({
ingress: ingressRouters[j],
egress: egressRouter,
- address: self.QDRService.utilities.addr_text(
- link.owningAddr
- ),
+ address: self.QDRService.utilities.addr_text(link.owningAddr),
messages: messages
});
}
@@ -237,11 +232,7 @@ let convert = function(self, values) {
self.last_values.values = JSON.parse(JSON.stringify(values));
self.last_values.timestamp = Date.now();
if (self.isRate) {
- self.rateValues = values = calcRate(
- values,
- self.last_values,
- self.snapshots
- );
+ self.rateValues = values = calcRate(values, self.last_values, self.snapshots);
}
// convert the raw data to a matrix
let matrix = self.converter(values, self.filter);
diff --git a/console/react/src/chord/matrix.js b/console/react/src/chord/matrix.js
index 156deb3..5377a16 100644
--- a/console/react/src/chord/matrix.js
+++ b/console/react/src/chord/matrix.js
@@ -16,8 +16,8 @@ KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
*/
-/* global d3 */
+import * as d3 from "d3";
const MIN_CHORD_THRESHOLD = 0.01;
// public Matrix object
@@ -27,12 +27,12 @@ function valuesMatrix(aggregate) {
}
// a matrix row
let valuesMatrixRow = function(r, chordName, ingress, egress) {
- this.chordName = chordName || '';
- this.ingress = ingress || '';
- this.egress = egress || '';
+ this.chordName = chordName || "";
+ this.ingress = ingress || "";
+ this.egress = egress || "";
this.index = r;
this.cols = [];
- for (let c=0; c<r; c++) {
+ for (let c = 0; c < r; c++) {
this.addCol(0);
}
};
@@ -45,35 +45,36 @@ let valuesMatrixCol = function(messages, row, c, address) {
};
// initialize a matrix with empty data with size rows and columns
-valuesMatrix.prototype.zeroInit = function (size) {
- for (let r=0; r<size; r++) {
+valuesMatrix.prototype.zeroInit = function(size) {
+ for (let r = 0; r < size; r++) {
this.addRow();
}
};
-valuesMatrix.prototype.setRowCol = function (r, c, ingress, egress, address, value) {
+valuesMatrix.prototype.setRowCol = function(r, c, ingress, egress, address, value) {
this.rows[r].ingress = ingress;
this.rows[r].egress = egress;
this.rows[r].cols[c].messages = value;
this.rows[r].cols[c].address = address;
};
-valuesMatrix.prototype.setColMessages = function (r, c, messages) {
+valuesMatrix.prototype.setColMessages = function(r, c, messages) {
this.rows[r].cols[c].messages = messages;
};
// return true if any of the matrix cells have messages
-valuesMatrix.prototype.hasValues = function () {
- return this.rows.some(function (row) {
- return row.cols.some(function (col) {
+valuesMatrix.prototype.hasValues = function() {
+ return this.rows.some(function(row) {
+ return row.cols.some(function(col) {
return col.messages > MIN_CHORD_THRESHOLD;
});
});
};
-valuesMatrix.prototype.getMinMax = function () {
- let min = Number.MAX_VALUE, max = Number.MIN_VALUE;
- this.rows.forEach( function (row) {
- row.cols.forEach( function (col) {
+valuesMatrix.prototype.getMinMax = function() {
+ let min = Number.MAX_VALUE,
+ max = Number.MIN_VALUE;
+ this.rows.forEach(function(row) {
+ row.cols.forEach(function(col) {
if (col.messages > MIN_CHORD_THRESHOLD) {
max = Math.max(max, col.messages);
min = Math.min(min, col.messages);
@@ -83,21 +84,22 @@ valuesMatrix.prototype.getMinMax = function () {
return [min, max];
};
// extract a square matrix with just the values from the object matrix
-valuesMatrix.prototype.matrixMessages = function () {
+valuesMatrix.prototype.matrixMessages = function() {
let m = emptyMatrix(this.rows.length);
- this.rows.forEach( function (row, r) {
- row.cols.forEach( function (col, c) {
+ this.rows.forEach(function(row, r) {
+ row.cols.forEach(function(col, c) {
m[r][c] = col.messages;
});
});
return m;
};
-valuesMatrix.prototype.getGroupBy = function () {
+valuesMatrix.prototype.getGroupBy = function() {
if (!this.aggregate && this.rows.length) {
let groups = [];
- let lastName = this.rows[0].egress, groupIndex = 0;
- this.rows.forEach( function (row) {
+ let lastName = this.rows[0].egress,
+ groupIndex = 0;
+ this.rows.forEach(function(row) {
if (row.egress !== lastName) {
groupIndex++;
lastName = row.egress;
@@ -105,107 +107,105 @@ valuesMatrix.prototype.getGroupBy = function () {
groups.push(groupIndex);
});
return groups;
- }
- else
- return d3.range(this.rows.length);
+ } else return d3.range(this.rows.length);
};
-valuesMatrix.prototype.chordName = function (i, ingress) {
- if (this.aggregate)
- return this.rows[i].chordName;
- return (ingress ? this.rows[i].ingress : this.rows[i].egress);
+valuesMatrix.prototype.chordName = function(i, ingress) {
+ if (this.aggregate) return this.rows[i].chordName;
+ return ingress ? this.rows[i].ingress : this.rows[i].egress;
};
-valuesMatrix.prototype.routerName = function (i) {
- if (this.aggregate)
- return this.rows[i].chordName;
- return getAttribute(this, 'egress', i);
+valuesMatrix.prototype.routerName = function(i) {
+ if (this.aggregate) return this.rows[i].chordName;
+ return getAttribute(this, "egress", i);
};
-valuesMatrix.prototype.getEgress = function (i) {
- return getAttribute(this, 'egress', i);
+valuesMatrix.prototype.getEgress = function(i) {
+ return getAttribute(this, "egress", i);
};
-valuesMatrix.prototype.getIngress = function (i) {
- return getAttribute(this, 'ingress', i);
+valuesMatrix.prototype.getIngress = function(i) {
+ return getAttribute(this, "ingress", i);
};
-valuesMatrix.prototype.getAddress = function (r, c) {
+valuesMatrix.prototype.getAddress = function(r, c) {
return this.rows[r].cols[c].address;
};
-valuesMatrix.prototype.getAddresses = function (r) {
+valuesMatrix.prototype.getAddresses = function(r) {
let addresses = {};
- this.rows[r].cols.forEach( function (c) {
- if (c.address && c.messages)
- addresses[c.address] = true;
+ this.rows[r].cols.forEach(function(c) {
+ if (c.address && c.messages) addresses[c.address] = true;
});
return Object.keys(addresses);
};
-let getAttribute = function (self, attr, i) {
- if (self.aggregate)
- return self.rows[i][attr];
+let getAttribute = function(self, attr, i) {
+ if (self.aggregate) return self.rows[i][attr];
let groupByIndex = self.getGroupBy().indexOf(i);
if (groupByIndex < 0) {
groupByIndex = i;
}
return self.rows[groupByIndex][attr];
};
-valuesMatrix.prototype.addRow = function (chordName, ingress, egress, address) {
+valuesMatrix.prototype.addRow = function(chordName, ingress, egress, address) {
let rowIndex = this.rows.length;
let newRow = new valuesMatrixRow(rowIndex, chordName, ingress, egress);
this.rows.push(newRow);
// add new column to all rows
- for (let r=0; r<=rowIndex; r++) {
+ for (let r = 0; r <= rowIndex; r++) {
this.rows[r].addCol(0, address);
}
return rowIndex;
};
-valuesMatrix.prototype.indexOf = function (chordName) {
- return this.rows.findIndex( function (row) {
+valuesMatrix.prototype.indexOf = function(chordName) {
+ return this.rows.findIndex(function(row) {
return row.chordName === chordName;
});
};
-valuesMatrix.prototype.addValue = function (r, c, value) {
+valuesMatrix.prototype.addValue = function(r, c, value) {
this.rows[r].cols[c].addMessages(value.messages);
this.rows[r].cols[c].setAddress(value.address);
};
-valuesMatrixRow.prototype.addCol = function (messages, address) {
+valuesMatrixRow.prototype.addCol = function(messages, address) {
this.cols.push(new valuesMatrixCol(messages, this, this.cols.length, address));
};
-valuesMatrixCol.prototype.addMessages = function (messages) {
+valuesMatrixCol.prototype.addMessages = function(messages) {
if (!(this.messages === MIN_CHORD_THRESHOLD && messages === MIN_CHORD_THRESHOLD))
this.messages += messages;
};
-valuesMatrixCol.prototype.setAddress = function (address) {
+valuesMatrixCol.prototype.setAddress = function(address) {
this.address = address;
};
-valuesMatrix.prototype.getChordList = function () {
- return this.rows.map( function (row) {
+valuesMatrix.prototype.getChordList = function() {
+ return this.rows.map(function(row) {
return row.chordName;
});
};
-valuesMatrix.prototype.sorted = function () {
+valuesMatrix.prototype.sorted = function() {
let newChordList = this.getChordList();
newChordList.sort();
let m = new valuesMatrix(this.aggregate);
m.zeroInit(this.rows.length);
- this.rows.forEach( function (row) {
- let chordName = row.chordName;
- row.cols.forEach( function (col, c) {
- let newRow = newChordList.indexOf(chordName);
- let newCol = newChordList.indexOf(this.rows[c].chordName);
- m.rows[newRow].chordName = chordName;
- m.rows[newRow].ingress = row.ingress;
- m.rows[newRow].egress = row.egress;
- m.rows[newRow].cols[newCol].messages = col.messages;
- m.rows[newRow].cols[newCol].address = col.address;
- }.bind(this));
- }.bind(this));
+ this.rows.forEach(
+ function(row) {
+ let chordName = row.chordName;
+ row.cols.forEach(
+ function(col, c) {
+ let newRow = newChordList.indexOf(chordName);
+ let newCol = newChordList.indexOf(this.rows[c].chordName);
+ m.rows[newRow].chordName = chordName;
+ m.rows[newRow].ingress = row.ingress;
+ m.rows[newRow].egress = row.egress;
+ m.rows[newRow].cols[newCol].messages = col.messages;
+ m.rows[newRow].cols[newCol].address = col.address;
+ }.bind(this)
+ );
+ }.bind(this)
+ );
return m;
};
// private helper function
-let emptyMatrix = function (size) {
+let emptyMatrix = function(size) {
let matrix = [];
- for(let i=0; i<size; i++) {
+ for (let i = 0; i < size; i++) {
matrix[i] = [];
- for(let j=0; j<size; j++) {
+ for (let j = 0; j < size; j++) {
matrix[i][j] = 0;
}
}
diff --git a/console/react/src/connect-form.js b/console/react/src/connect-form.js
index 77ffc55..009af85 100644
--- a/console/react/src/connect-form.js
+++ b/console/react/src/connect-form.js
@@ -36,16 +36,11 @@ class ConnectForm extends React.Component {
port: "",
username: "",
password: "",
- isShown: this.props.isConnectFormOpen,
connecting: false,
connectError: null
};
}
- show = isShown => {
- this.setState({ isShown });
- };
-
componentDidMount = () => {
let savedValues = localStorage.getItem(CONNECT_KEY);
if (!savedValues) {
@@ -62,6 +57,7 @@ class ConnectForm extends React.Component {
}
this.setState(savedValues);
};
+
handleTextInputChange = (field, value) => {
const formValues = Object.assign(this.state);
formValues[field] = value;
@@ -93,9 +89,12 @@ class ConnectForm extends React.Component {
e => {
console.log(e);
this.setState({ connecting: false, connectError: e.message });
- this.props.handleAddNotification("action", `Connect failed with message: ${e.message}`,
+ this.props.handleAddNotification(
+ "action",
+ `Connect failed with message: ${e.message}`,
new Date(),
- "danger")
+ "danger"
+ );
}
);
});
@@ -107,17 +106,8 @@ class ConnectForm extends React.Component {
};
render() {
- const {
- isShown,
- address,
- port,
- username,
- password,
- connecting,
- connectError
- } = this.state;
-
- return isShown ? (
+ const { address, port, username, password, connecting, connectError } = this.state;
+ return this.props.isConnectFormOpen ? (
<div>
<div className="connect-modal">
<div className={connecting ? "connecting" : ""}>
@@ -125,15 +115,10 @@ class ConnectForm extends React.Component {
<TextContent className="connect-title">
<Text component={TextVariants.h1}>Connect</Text>
<Text component={TextVariants.p}>
- Enter the address and an HTTP-enabled port of a qpid dispatch
- router.
+ Enter the address and an HTTP-enabled port of a qpid dispatch router.
</Text>
</TextContent>
- <FormGroup
- label="Address"
- isRequired
- fieldId={`form-address-${this.props.prefix}`}
- >
+ <FormGroup label="Address" isRequired fieldId={`form-address-${this.props.prefix}`}>
<TextInput
value={address}
isRequired
@@ -141,16 +126,10 @@ class ConnectForm extends React.Component {
id={`form-address-${this.props.prefix}`}
aria-describedby="horizontal-form-address-helper"
name="form-address"
- onChange={value =>
- this.handleTextInputChange("address", value)
- }
+ onChange={value => this.handleTextInputChange("address", value)}
/>
</FormGroup>
- <FormGroup
- label="Port"
- isRequired
- fieldId={`form-port-${this.props.prefix}`}
- >
+ <FormGroup label="Port" isRequired fieldId={`form-port-${this.props.prefix}`}>
<TextInput
value={port}
onChange={value => this.handleTextInputChange("port", value)}
@@ -160,29 +139,19 @@ class ConnectForm extends React.Component {
name="form-port"
/>
</FormGroup>
- <FormGroup
- label="User name"
- fieldId={`form-user-${this.props.prefix}`}
- >
+ <FormGroup label="User name" fieldId={`form-user-${this.props.prefix}`}>
<TextInput
value={username}
- onChange={value =>
- this.handleTextInputChange("username", value)
- }
+ onChange={value => this.handleTextInputChange("username", value)}
isRequired
id={`form-user-${this.props.prefix}`}
name="form-user"
/>
</FormGroup>
- <FormGroup
- label="Password"
- fieldId={`form-password-${this.props.prefix}`}
- >
+ <FormGroup label="Password" fieldId={`form-password-${this.props.prefix}`}>
<TextInput
value={password}
- onChange={value =>
- this.handleTextInputChange("password", value)
- }
+ onChange={value => this.handleTextInputChange("password", value)}
type="password"
id={`form-password-${this.props.prefix}`}
name="form-password"
@@ -190,9 +159,7 @@ class ConnectForm extends React.Component {
</FormGroup>
{connectError && (
<TextContent className="connect-error">
- <Text component={TextVariants.p}>
- {connectError}
- </Text>
+ <Text component={TextVariants.p}>{connectError}</Text>
</TextContent>
)}
<ActionGroup>
diff --git a/console/react/src/connectPage.js b/console/react/src/connectPage.js
index ac54e9c..724c3f7 100644
--- a/console/react/src/connectPage.js
+++ b/console/react/src/connectPage.js
@@ -1,10 +1,5 @@
import React from "react";
-import {
- PageSection,
- PageSectionVariants,
- TextContent,
- Text
-} from "@patternfly/react-core";
+import { PageSection, PageSectionVariants, TextContent, Text } from "@patternfly/react-core";
import ConnectForm from "./connect-form";
class ConnectPage extends React.Component {
@@ -20,15 +15,11 @@ class ConnectPage extends React.Component {
shouldComponentUpdate = (nextProps, nextState) => {
if (nextState.showForm !== this.state.showForm) return true;
const nextPathname =
- nextProps.location &&
- nextProps.location.state &&
- nextProps.location.state.pathname
+ nextProps.location && nextProps.location.state && nextProps.location.state.pathname
? nextProps.location.state.pathname
: undefined;
const currentPathname =
- this.props.location &&
- this.props.location.state &&
- this.props.location.state.pathname
+ this.props.location && this.props.location.state && this.props.location.state.pathname
? this.props.location.state.pathname
: undefined;
@@ -40,10 +31,7 @@ class ConnectPage extends React.Component {
const { from } = this.props.location.state || { from: { pathname: "/" } };
return (
<React.Fragment>
- <PageSection
- variant={PageSectionVariants.light}
- className="connect-page"
- >
+ <PageSection variant={PageSectionVariants.light} className="connect-page">
{showForm ? (
<ConnectForm
prefix="form"
@@ -55,8 +43,8 @@ class ConnectPage extends React.Component {
isConnectFormOpen={true}
/>
) : (
- <React.Fragment />
- )}
+ <React.Fragment />
+ )}
<div className="left-content">
<TextContent>
<Text component="h1" className="console-banner">
@@ -65,12 +53,10 @@ class ConnectPage extends React.Component {
</TextContent>
<TextContent>
<Text component="p">
- The console is an HTML based web site that displays information
- about a qpid dispatch router network. The console only provides
- limited information about the clients that are attached to the
- router network and is therfore more appropriate for
- administrators needing to know the layout and health of the
- router network.
+ The console is an HTML based web site that displays information about a qpid
+ dispatch router network. The console only provides limited information about the
+ clients that are attached to the router network and is therfore more appropriate for
+ administrators needing to know the layout and health of the router network.
</Text>
</TextContent>
</div>
diff --git a/console/react/src/details/schema/schemaPage.js b/console/react/src/details/schema/schemaPage.js
index b49b612..b18198b 100644
--- a/console/react/src/details/schema/schemaPage.js
+++ b/console/react/src/details/schema/schemaPage.js
@@ -19,13 +19,7 @@ under the License.
import React from "react";
import { PageSection, PageSectionVariants } from "@patternfly/react-core";
-import {
- Stack,
- StackItem,
- TextContent,
- Text,
- TextVariants
-} from "@patternfly/react-core";
+import { Stack, StackItem, TextContent, Text, TextVariants } from "@patternfly/react-core";
import { Card, CardBody } from "@patternfly/react-core";
class SchemaPage extends React.Component {
@@ -36,8 +30,7 @@ class SchemaPage extends React.Component {
root: {
key: "entities",
title: "Schema entities",
- description:
- "List of management entities. Click on an entity to view its attributes.",
+ description: "List of management entities. Click on an entity to view its attributes.",
hidden: false
}
};
@@ -90,8 +83,7 @@ class SchemaPage extends React.Component {
if (obj.type) {
child.attributes.push({
key: "type",
- value:
- obj.type.constructor === Array ? `[${obj.type.join(", ")}]` : obj.type
+ value: obj.type.constructor === Array ? `[${obj.type.join(", ")}]` : obj.type
});
}
if (obj.default) {
@@ -154,23 +146,15 @@ class SchemaPage extends React.Component {
<div className="list-view-pf-main-info">
<div className="list-view-pf-left">
<span
- className={`pficon ${this.folderIconClass(
- itemInfo
- )} list-view-pf-icon-sm`}
+ className={`pficon ${this.folderIconClass(itemInfo)} list-view-pf-icon-sm`}
></span>
</div>
<div className="list-view-pf-body">
<div className="list-view-pf-description">
- <div className="list-group-item-heading">
- {itemInfo.title}
- </div>
+ <div className="list-group-item-heading">{itemInfo.title}</div>
<div className="list-group-item-text">
{itemInfo.description}
- {itemInfo.fqt && (
- <div className="list-group-item-fqt">
- {itemInfo.fqt}
- </div>
- )}
+ {itemInfo.fqt && <div className="list-group-item-fqt">{itemInfo.fqt}</div>}
</div>
</div>
<div className="list-view-pf-additional-info">
@@ -189,8 +173,7 @@ class SchemaPage extends React.Component {
</div>
</div>
</div>
- {itemInfo.children &&
- itemInfo.children.map(childInfo => TreeItem(childInfo))}
+ {itemInfo.children && itemInfo.children.map(childInfo => TreeItem(childInfo))}
</div>
</div>
)
diff --git a/console/react/src/details/schema/schemaPage.test.js b/console/react/src/details/schema/schemaPage.test.js
index 5e39cc0..7954c8e 100644
--- a/console/react/src/details/schema/schemaPage.test.js
+++ b/console/react/src/details/schema/schemaPage.test.js
@@ -1,17 +1,14 @@
import React from "react";
-import { render, fireEvent } from '@testing-library/react';
+import { render, fireEvent } from "@testing-library/react";
import { mockService } from "../../qdrService.mock";
import SchemaPage from "./schemaPage";
-it('renders a SchemaPage', () => {
+it("renders a SchemaPage", () => {
const service = mockService({});
const props = {
schema: service.schema
- }
- const {
- getByTestId,
- queryByTestId
- } = render(<SchemaPage {...props} />);
+ };
+ const { getByTestId, queryByTestId } = render(<SchemaPage {...props} />);
// the root node should be present
const root = getByTestId("entities");
@@ -22,8 +19,11 @@ it('renders a SchemaPage', () => {
let addressEntity = getByTestId("address");
expect(addressEntity).toBeInTheDocument();
+ fireEvent.click(addressEntity);
+ expect(getByTestId("address-egressPhase")).toBeInTheDocument();
+
// clicking on the root should collapse the tree
fireEvent.click(root);
addressEntity = queryByTestId("address");
expect(addressEntity).toBeNull();
-})
\ No newline at end of file
+});
diff --git a/console/react/src/layout.js b/console/react/src/layout.js
index c1c2624..4bd80e7 100644
--- a/console/react/src/layout.js
+++ b/console/react/src/layout.js
@@ -36,13 +36,7 @@ import {
PageSidebar
} from "@patternfly/react-core";
-import {
- BrowserRouter as Router,
- Switch,
- Route,
- Link,
- Redirect
-} from "react-router-dom";
+import { BrowserRouter as Router, Switch, Route, Link, Redirect } from "react-router-dom";
import accessibleStyles from "@patternfly/patternfly/utilities/Accessibility/accessibility.css";
import { css } from "@patternfly/react-styles";
@@ -72,10 +66,10 @@ class PageLayout extends React.Component {
isNavOpenDesktop: true,
isNavOpenMobile: false,
isMobileView: false,
- user: "anonymous"
+ user: "anonymous",
+ isConnectFormOpen: false
};
this.isDropdownOpen = false;
- this.isConnectFormOpen = false;
this.service = this.props.service;
this.service.setHooks({ setLocation: this.setLocation });
@@ -88,10 +82,7 @@ class PageLayout extends React.Component {
{ name: "connections", pre: true },
{ name: "logs", pre: true }
],
- visualizations: [
- { name: "topology" },
- { name: "flow", title: "Message flow" }
- ],
+ visualizations: [{ name: "topology" }, { name: "flow", title: "Message flow" }],
details: [{ name: "entities" }, { name: "schema" }]
};
}
@@ -130,12 +121,7 @@ class PageLayout extends React.Component {
this.setState({ connectPath: "", connected: false }, () => {
this.handleConnectCancel();
this.service.disconnect();
- this.handleAddNotification(
- "event",
- "Manually disconnected",
- new Date(),
- "info"
- );
+ this.handleAddNotification("event", "Manually disconnected", new Date(), "info");
});
} else {
this.schema = this.service.schema;
@@ -150,12 +136,7 @@ class PageLayout extends React.Component {
}
}
this.handleConnectCancel();
- this.handleAddNotification(
- "event",
- `Console connected to router`,
- new Date(),
- "success"
- );
+ this.handleAddNotification("event", `Console connected to router`, new Date(), "success");
this.setState({
activeItem,
@@ -176,14 +157,11 @@ class PageLayout extends React.Component {
};
toggleConnectForm = () => {
- this.isConnectFormOpen = !this.isConnectFormOpen;
- this.connectFormRef.show(this.isConnectFormOpen);
+ this.setState({ isConnectFormOpen: !this.state.isConnectFormOpen });
};
handleConnectCancel = () => {
- if (this.connectFormRef)
- this.connectFormRef.show(false);
- this.isConnectFormOpen = false;
+ this.setState({ isConnectFormOpen: false });
};
onNavToggleDesktop = () => {
@@ -244,12 +222,7 @@ class PageLayout extends React.Component {
{this.nav[section].map(item => {
const key = item.name;
return (
- <NavItem
- groupId={section}
- itemId={key}
- isActive={activeItem === key}
- key={key}
- >
+ <NavItem groupId={section} itemId={key} isActive={activeItem === key} key={key}>
<Link to={`/${item.pre ? section + "/" : ""}${key}`}>
{item.title ? item.title : utils.Icap(key)}
</Link>
@@ -264,12 +237,7 @@ class PageLayout extends React.Component {
);
const PageToolbar = (
<Toolbar>
- <ToolbarGroup
- className={css(
- accessibleStyles.screenReader,
- accessibleStyles.visibleOnLg
- )}
- >
+ <ToolbarGroup className={css(accessibleStyles.screenReader, accessibleStyles.visibleOnLg)}>
<ToolbarItem>
<Button
id="connectButton"
@@ -285,16 +253,8 @@ class PageLayout extends React.Component {
</ToolbarItem>
</ToolbarGroup>
<ToolbarGroup>
- <ToolbarItem
- className={css(
- accessibleStyles.screenReader,
- accessibleStyles.visibleOnMd
- )}
- >
- <DropdownToggle
- className="user-button"
- onToggle={this.onDropdownToggle}
- >
+ <ToolbarItem className={css(accessibleStyles.screenReader, accessibleStyles.visibleOnMd)}>
+ <DropdownToggle className="user-button" onToggle={this.onDropdownToggle}>
{this.state.user}
</DropdownToggle>
<DropdownMenu
@@ -316,28 +276,26 @@ class PageLayout extends React.Component {
toolbar={PageToolbar}
avatar={<Avatar src="./assets/img_avatar.svg" alt="Avatar image" />}
showNavToggle
- onNavToggle={
- isMobileView ? this.onNavToggleMobile : this.onNavToggleDesktop
- }
+ onNavToggle={isMobileView ? this.onNavToggleMobile : this.onNavToggleDesktop}
isNavOpen={isMobileView ? isNavOpenMobile : isNavOpenDesktop}
/>
);
const pageId = "main-content-page-layout-manual-nav";
- const PageSkipToContent = (
- <SkipToContent href={`#${pageId}`}>Skip to Content</SkipToContent>
- );
+ const PageSkipToContent = <SkipToContent href={`#${pageId}`}>Skip to Content</SkipToContent>;
const sidebar = PageNav => {
if (this.state.connected) {
return (
<PageSidebar
+ id="page-sidebar"
nav={PageNav}
isNavOpen={isMobileView ? isNavOpenMobile : isNavOpenDesktop}
theme="dark"
/>
);
}
- return <React.Fragment />;
+ // this is required to prevent an axe error
+ return <div id="page-sidebar" />;
};
// don't allow access to this component unless we are logged in
@@ -354,10 +312,8 @@ class PageLayout extends React.Component {
{...more}
/>
) : (
- <Redirect
- to={{ pathname: "/login", state: { from: props.location } }}
- />
- )
+ <Redirect to={{ pathname: "/login", state: { from: props.location } }} />
+ )
}
/>
);
@@ -377,13 +333,13 @@ class PageLayout extends React.Component {
const connectForm = () => {
return (
<ConnectForm
- ref={el => (this.connectFormRef = el)}
service={this.service}
- isConnectFormOpen={this.isConnectFormOpen}
+ isConnectFormOpen={this.state.isConnectFormOpen}
fromPath={"/"}
handleConnect={this.handleConnect}
handleConnectCancel={this.handleConnectCancel}
isConnected={this.state.connected}
+ fromLayout={true}
/>
);
};
@@ -398,28 +354,17 @@ class PageLayout extends React.Component {
skipToContent={PageSkipToContent}
mainContainerId={pageId}
>
- {this.isConnectFormOpen && connectForm()}
+ {connectForm()}
<Switch>
<PrivateRoute path="/" exact component={DashboardPage} />
<PrivateRoute path="/dashboard" component={DashboardPage} />
- <PrivateRoute
- path="/overview/:entity"
- component={OverviewPage}
- />
- <PrivateRoute
- path="/details"
- schema={this.schema}
- component={DetailsTablePage}
- />
+ <PrivateRoute path="/overview/:entity" component={OverviewPage} />
+ <PrivateRoute path="/details" schema={this.schema} component={DetailsTablePage} />
<PrivateRoute path="/topology" component={TopologyPage} />
<PrivateRoute path="/flow" component={MessageFlowPage} />
<PrivateRoute path="/logs" component={LogDetails} />
<PrivateRoute path="/entities" component={EntitiesPage} />
- <PrivateRoute
- path="/schema"
- schema={this.schema}
- component={SchemaPage}
- />
+ <PrivateRoute path="/schema" schema={this.schema} component={SchemaPage} />
<Route
path="/login"
render={props => (
diff --git a/console/react/src/overview/dashboard/dashboardPage.js b/console/react/src/overview/dashboard/dashboardPage.js
index 7183076..7116a78 100644
--- a/console/react/src/overview/dashboard/dashboardPage.js
+++ b/console/react/src/overview/dashboard/dashboardPage.js
@@ -61,7 +61,7 @@ class DashboardPage extends React.Component {
onClick={() => this.setTimePeriod(60)}
className={`pf-c-nav__item ${
this.state.timePeriod === 60 ? "selected" : ""
- }`}
+ }`}
>
Min
</li>
@@ -69,7 +69,7 @@ class DashboardPage extends React.Component {
onClick={() => this.setTimePeriod(60 * 60)}
className={`pf-c-nav__item ${
this.state.timePeriod === 60 ? "" : "selected"
- }`}
+ }`}
>
Hour
</li>
@@ -77,19 +77,11 @@ class DashboardPage extends React.Component {
</nav>
</div>
</div>
- <div className="time-period">
- For the past {this.timePeriodString()}
- </div>
+ <div className="time-period">For the past {this.timePeriodString()}</div>
</CardHeader>
<CardBody>
- <ThroughputChart
- period={this.state.timePeriod}
- service={this.props.service}
- />
- <InflightChart
- period={this.state.timePeriod}
- service={this.props.service}
- />
+ <ThroughputChart period={this.state.timePeriod} service={this.props.service} />
+ <InflightChart period={this.state.timePeriod} service={this.props.service} />
</CardBody>
</Card>
</StackItem>
@@ -99,10 +91,7 @@ class DashboardPage extends React.Component {
<ActiveAddressesCard service={this.props.service} />
</SplitItem>
<SplitItem className="fill-card">
- <DelayedDeliveriesCard
- {...this.props}
- service={this.props.service}
- />
+ <DelayedDeliveriesCard {...this.props} service={this.props.service} />
</SplitItem>
</Split>
</StackItem>
diff --git a/console/react/src/overview/dashboard/delayedDeliveriesCard.js b/console/react/src/overview/dashboard/delayedDeliveriesCard.js
index e6aaf4d..0fa44b3 100644
--- a/console/react/src/overview/dashboard/delayedDeliveriesCard.js
+++ b/console/react/src/overview/dashboard/delayedDeliveriesCard.js
@@ -25,13 +25,7 @@ class DelayedDeliveriesCard extends React.Component {
}
closeButton = (value, extraInfo) => {
- return (
- <ConnectionClose
- extraInfo={extraInfo}
- {...this.props}
- service={this.props.service}
- />
- );
+ return <ConnectionClose extraInfo={extraInfo} {...this.props} service={this.props.service} />;
};
componentDidMount = () => {
@@ -56,10 +50,7 @@ class DelayedDeliveriesCard extends React.Component {
let response = nodes[node]["router.link"];
// eslint-disable-next-line no-loop-func
response.results.forEach(result => {
- let link = this.props.service.utilities.flatten(
- response.attributeNames,
- result
- );
+ let link = this.props.service.utilities.flatten(response.attributeNames, result);
if (link.linkType === "endpoint") {
link.router = this.props.service.utilities.nameFromId(node);
link.role = "normal";
@@ -70,9 +61,7 @@ class DelayedDeliveriesCard extends React.Component {
connection
);
if (link.connectionId === conn.identity) {
- link.connection = this.props.service.utilities.clientName(
- conn
- );
+ link.connection = this.props.service.utilities.clientName(conn);
return true;
}
return false;
@@ -84,14 +73,8 @@ class DelayedDeliveriesCard extends React.Component {
link.name,
12 // average over 12 snapshots (each snapshot is 5 seconds apart)
);
- link.deliveriesDelayed1SecRate = Math.round(
- delayedRates.deliveriesDelayed1Sec,
- 1
- );
- link.deliveriesDelayed10SecRate = Math.round(
- delayedRates.deliveriesDelayed10Sec,
- 1
- );
+ link.deliveriesDelayed1SecRate = Math.round(delayedRates.deliveriesDelayed1Sec, 1);
+ link.deliveriesDelayed10SecRate = Math.round(delayedRates.deliveriesDelayed10Sec, 1);
/* The killConnection event handler (in qdrOverview.js) expects
a row object with a routerId and the identity of a connection.
Here we set those attributes so that when killConnection is
@@ -107,16 +90,11 @@ class DelayedDeliveriesCard extends React.Component {
if (links.length === 0) return;
// update the grid's data
links = links.filter(link => {
- return (
- link.deliveriesDelayed1SecRate > 0 ||
- link.deliveriesDelayed10SecRate > 0
- );
+ return link.deliveriesDelayed1SecRate > 0 || link.deliveriesDelayed10SecRate > 0;
});
links.sort((a, b) => {
- if (a.deliveriesDelayed1SecRate > b.deliveriesDelayed1SecRate)
- return -1;
- else if (a.deliveriesDelayed1SecRate < b.deliveriesDelayed1SecRate)
- return 1;
+ if (a.deliveriesDelayed1SecRate > b.deliveriesDelayed1SecRate) return -1;
+ else if (a.deliveriesDelayed1SecRate < b.deliveriesDelayed1SecRate) return 1;
else if (a.unsettledCount > b.unsettledCount) return -1;
else if (a.unsettledCount < b.unsettledCount) return 1;
else return 0;
@@ -143,9 +121,7 @@ class DelayedDeliveriesCard extends React.Component {
};
nextUpdateString = () => {
- const nextUpdate = new Date(
- this.state.lastUpdate.getTime() + UPDATE_INTERVAL
- );
+ const nextUpdate = new Date(this.state.lastUpdate.getTime() + UPDATE_INTERVAL);
return this.props.service.utilities.strDate(nextUpdate);
};
diff --git a/console/react/src/qdrService.mock.js b/console/react/src/qdrService.mock.js
index d2f4e3b..c1229f9 100644
--- a/console/react/src/qdrService.mock.js
+++ b/console/react/src/qdrService.mock.js
@@ -18,2128 +18,52 @@ under the License.
*/
import { utils } from "./amqp/utilities";
+import fetchResults from "../test_data/fetchEntities";
+import nodeInfo from "../test_data/nodeInfo";
+import schema from "../test_data/schema";
const methodResults = {
context: {
- message:
- {
+ message: {
application_properties: {
statusCode: 200,
statusDescription: "fake response was OK"
}
}
}
-}
-
-const nodeInfo = {
- "amqp:/_topo/0/A/$management": {
- "connection": {
- "attributeNames": [
- "name",
- "identity",
- "host",
- "role",
- "dir",
- "container",
- "sasl",
- "isAuthenticated",
- "user",
- "isEncrypted",
- "sslProto",
- "sslCipher",
- "properties",
- "sslSsf",
- "tenant",
- "type",
- "ssl",
- "opened",
- "active",
- "adminStatus",
- "operStatus"
- ],
- "results": [
- [
- "connection/127.0.0.1:41076",
- "1",
- "127.0.0.1:41076",
- "inter-router",
- "in",
- "D",
- "ANONYMOUS",
- true,
- "anonymous",
- false,
- null,
- null,
- {
- "product": "qpid-dispatch-router",
- "version": "1.9.0-SNAPSHOT",
- "qd.conn-id": 622
- },
- 0,
- null,
- "org.apache.qpid.dispatch.connection",
- false,
- true,
- true,
- "enabled",
- "up"
- ],
- [
- "connection/127.0.0.1:34276",
- "3",
- "127.0.0.1:34276",
- "normal",
- "in",
- "87c75b00-3eae-4289-b2ef-7faae85682b3",
- "ANONYMOUS",
- true,
- "anonymous",
- false,
- null,
- null,
- {},
- 0,
- null,
- "org.apache.qpid.dispatch.connection",
- false,
- true,
- true,
- "enabled",
- "up"
- ],
- [
- "connection/::1",
- "11",
- "::1",
- "normal",
- "in",
- "d5bf3869-55dc-9c4b-8580-ae0c51d09d82",
- null,
- false,
- "anonymous",
- false,
- null,
- null,
- {
- "console_identifier": "Dispatch console"
- },
- 0,
- null,
- "org.apache.qpid.dispatch.connection",
- false,
- true,
- true,
- "enabled",
- "up"
- ]
- ],
- "timestamp": "2019-11-14T14:46:18.732Z"
- }
- },
- "amqp:/_topo/0/D/$management": {
- "connection": {
- "attributeNames": [
- "name",
- "identity",
- "host",
- "role",
- "dir",
- "container",
- "sasl",
- "isAuthenticated",
- "user",
- "isEncrypted",
- "sslProto",
- "sslCipher",
- "properties",
- "sslSsf",
- "tenant",
- "type",
- "ssl",
- "opened",
- "active",
- "adminStatus",
- "operStatus"
- ],
- "results": [
- [
- "connection/0.0.0.0:2000",
- "622",
- "0.0.0.0:2000",
- "inter-router",
- "out",
- "A",
- "ANONYMOUS",
- true,
- null,
- false,
- null,
- null,
- {
- "product": "qpid-dispatch-router",
- "version": "1.9.0-SNAPSHOT",
- "qd.conn-id": 1
- },
- 0,
- null,
- "org.apache.qpid.dispatch.connection",
- false,
- true,
- true,
- "enabled",
- "up"
- ]
- ],
- "timestamp": "2019-11-14T14:46:18.734Z"
- }
- }
-}
+};
export const mockService = ({ onSendMethod }) => {
- const cbSendMethod = onSendMethod ? onSendMethod : () => { }
+ const cbSendMethod = onSendMethod ? onSendMethod : () => {};
return {
management: {
- connection:
- {
+ connection: {
sendMethod: () => {
cbSendMethod();
- return Promise.resolve(methodResults)
+ return Promise.resolve(methodResults);
}
},
topology: {
- setUpdateEntities: () => { },
- ensureAllEntities: () => { },
- startUpdating: () => { },
- stopUpdating: () => { },
- addChangedAction: () => { },
- delChangedAction: () => { },
- addUpdatedAction: () => { },
- delUpdatedAction: () => { },
- fetchAllEntities: () => { },
- nodeInfo: () => (nodeInfo),
+ setUpdateEntities: () => {},
+ ensureAllEntities: (stuff, cb) => cb(),
+ ensureEntities: (foo, bar, cb) => cb(foo, fetchResults),
+ startUpdating: () => {},
+ stopUpdating: () => {},
+ addChangedAction: () => {},
+ delChangedAction: () => {},
+ addUpdatedAction: () => {},
+ delUpdatedAction: () => {},
+ fetchAllEntities: (stuff, cb) => {
+ cb(fetchResults);
+ },
+ fetchEntities: (foo, bar, cb) => cb(fetchResults),
+ nodeInfo: () => nodeInfo,
_nodeInfo: nodeInfo
}
},
utilities: utils,
connect: () => Promise.resolve(),
- schema: {
- "prefix": "org.apache.qpid.dispatch",
- "entityTypes": {
- "dummy": {
- "operations": [
- "CREATE",
- "READ",
- "UPDATE",
- "DELETE",
- "CALLME"
- ],
- "attributes": {
- "num1": {
- "type": "integer"
- },
- "num2": {
- "type": "integer"
- },
- "arg1": {
- "type": "string"
- },
- "arg2": {
- "type": "string"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.dummy",
- "description": "Dummy entity for test purposes."
- },
- "binding": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "matchedCount": {
- "type": "integer",
- "description": "Total number of deliveries that matched this binding."
- },
- "bindingKey": {
- "type": "string",
- "description": "Pattern to compare against incoming message's subject. The key is a string of zero or more tokens and wildcards. The format depends on the matchMethod configured for the exchange. For AMQP each token is delimited by the '.' character and wild-card tokens '*' matches a single token and '#' matches zero or more tokens. For MQTT each token is delimited by the '/' character and wildcard tokens '+' matches a single token and '#' matches zero or more tokens at th [...]
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "nextHopAddress": {
- "required": true,
- "type": "string",
- "description": "The address to forward the message to when the message's topic string matches the binding key pattern. This address is used by message consumers as the source of incoming messages."
- },
- "exchangeName": {
- "required": true,
- "type": "string",
- "description": "The name of the exchange to bind."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "nextHopPhase": {
- "type": "integer",
- "description": "The address phase used when forwarding messages that match this binding."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.config.binding",
- "description": "[EXPERIMENTAL] Defines a keyed next hop binding for a topic exchange. The subject field of the messages arriving at the exchange is compared against the binding's key value using the exchange's matchMethod. If the subject matches the key the message is forwarded to the nextHopAddress. The nextHopAddress overrides the message's original destination."
- },
- "entity": {
- "attributes": {
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.entity",
- "description": "Base entity type for all entities."
- },
- "router.connection.linkRoute": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "pattern": {
- "required": true,
- "type": "string",
- "description": "A wildcarded pattern for address matching. Incoming addresses are matched against this pattern. Matching addresses use the configured settings. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, a [...]
- },
- "direction": {
- "required": true,
- "type": [
- "in",
- "out"
- ],
- "description": "The permitted direction of links: 'in' means client senders; 'out' means client receivers"
- },
- "containerId": {
- "type": "string",
- "description": "Name of the container which has instantiated this linkRoute."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.connection.linkRoute",
- "description": "[EXPERIMENTAL] A linkRoute that is scoped to the connection that created it. Connection linkRoutes only exist within the context of a connection and when the connection is closed, they vanish. This differs from configured linkRoutes (router.config.linkRoute) which remain configured should their associated connection restart. Connection linkRoutes may be used by a client to create link-routed message flows that are automatically removed when the client disconnect [...]
- },
- "sslProfile": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "certFile": {
- "type": "path",
- "description": "The absolute path to the file containing the PEM-formatted public certificate to be used on the local end of any connections using this profile."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "uidNameMappingFile": {
- "type": "string",
- "description": "The absolute path to the file containing the unique id to display name mapping"
- },
- "ciphers": {
- "type": "string",
- "description": "Specifies the enabled ciphers so the SSL Ciphers can be hardened. In other words, use this field to disable weak ciphers. The ciphers are specified in the format understood by the OpenSSL library. For example, ciphers can be set to ALL:!aNULL:!EXPORT56:RC4+RSA:+HIGH:+MEDIUM:+LOW:+SSLv2:+EXP; -- The full list of allowed ciphers can be viewed using the openssl ciphers command"
- },
- "uidFormat": {
- "type": "string",
- "description": "A list of x509 client certificate fields that will be used to build a string that will uniquely identify the client certificate owner. For e.g. a value of 'cou' indicates that the uid will consist of c - common name concatenated with o - organization-company name concatenated with u - organization unit; or a value of 'o2' indicates that the uid will consist of o (organization name) concatenated with 2 (the sha256 fingerprint of the entire certificate) . Allo [...]
- },
- "privateKeyFile": {
- "type": "path",
- "description": "The absolute path to the file containing the PEM-formatted private key for the above certificate."
- },
- "protocols": {
- "type": "string",
- "description": "The TLS protocols that this sslProfile can use. You can specify a list of one or more of TLSv1, TLSv1.1, or TLSv1.2. To specify multiple protocols, separate the protocols with a space. For example, to permit the sslProfile to use TLS v1.1 and TLS v1.2 only, you would set the value to TLSv1.1 TLSv1.2. If you do not specify a value, the sslProfile uses the TLS protocol specified by the system-wide configuration."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "passwordFile": {
- "type": "path",
- "description": "If the above private key is password protected, this is the absolute path to a file containing the password that unlocks the certificate key. This file should be permission protected to limit access"
- },
- "caCertFile": {
- "type": "path",
- "description": "The absolute path to the database that contains the public certificates of trusted certificate authorities (CA)."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.sslProfile",
- "description": "Attributes for setting TLS/SSL configuration for connections."
- },
- "linkRoute": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "direction": {
- "required": true,
- "type": [
- "in",
- "out"
- ],
- "description": "The permitted direction of links: 'in' means client senders; 'out' means client receivers"
- },
- "addExternalPrefix": {
- "type": "string",
- "description": "add the specified prefix to the address of the remote terminus on the route container link"
- },
- "operStatus": {
- "type": [
- "inactive",
- "active"
- ],
- "description": "The operational status of this linkRoute: inactive - The remote container is not connected; active - the remote container is connected and ready to accept link routed attachments."
- },
- "pattern": {
- "type": "string",
- "description": "A wildcarded pattern for address matching. Link addresses are matched against this pattern. Matching addresses use the configured settings. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and e [...]
- },
- "connection": {
- "type": "string",
- "description": "The name from a connector or listener. Only one of containerId or connection should be specified for a linkRoute. Specifying both will result in the linkRoute not being created."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "prefix": {
- "type": "string",
- "description": "The address prefix for the configured settings. Cannot be used with the pattern attribute."
- },
- "distribution": {
- "default": "linkBalanced",
- "type": [
- "linkBalanced"
- ],
- "description": "Treatment of traffic associated with the address"
- },
- "delExternalPrefix": {
- "type": "string",
- "description": "remove the specified prefix to the address of the remote terminus on the route container link"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "containerId": {
- "type": "string",
- "description": "ContainerID for the target container. Only one of containerId or connection should be specified for a linkRoute. Specifying both will result in the linkRoute not being created."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.config.linkRoute",
- "description": "Entity type for link-route configuration. This is used to identify remote containers that shall be destinations for routed link-attaches. The link-routing configuration applies to an addressing space defined by a prefix or a pattern."
- },
- "allocator": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "heldByThreads": {
- "graph": true,
- "type": "integer"
- },
- "typeSize": {
- "type": "integer"
- },
- "transferBatchSize": {
- "type": "integer"
- },
- "globalFreeListMax": {
- "graph": true,
- "type": "integer"
- },
- "batchesRebalancedToGlobal": {
- "graph": true,
- "type": "integer"
- },
- "typeName": {
- "type": "string"
- },
- "batchesRebalancedToThreads": {
- "graph": true,
- "type": "integer"
- },
- "totalFreeToHeap": {
- "graph": true,
- "type": "integer"
- },
- "totalAllocFromHeap": {
- "graph": true,
- "type": "integer"
- },
- "localFreeListMax": {
- "graph": true,
- "type": "integer"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.allocator",
- "description": "Memory allocation pool."
- },
- "management": {
- "operations": [
- "GET-SCHEMA",
- "GET-JSON-SCHEMA",
- "GET-LOG",
- "PROFILE",
- "QUERY",
- "GET-TYPES",
- "GET-ANNOTATIONS",
- "GET-OPERATIONS",
- "GET-ATTRIBUTES",
- "GET-MGMT-NODES",
- "READ"
- ],
- "attributes": {
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "singleton": true,
- "fullyQualifiedType": "org.apache.qpid.dispatch.management",
- "description": "Qpid dispatch router extensions to the standard org.amqp.management interface."
- },
- "log": {
- "operations": [
- "UPDATE",
- "READ"
- ],
- "attributes": {
- "outputFile": {
- "type": "string",
- "description": "Where to send log messages. Can be 'stderr', 'stdout', 'syslog' or a file name."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "module": {
- "required": true,
- "type": [
- "ROUTER",
- "ROUTER_CORE",
- "ROUTER_HELLO",
- "ROUTER_LS",
- "ROUTER_MA",
- "MESSAGE",
- "SERVER",
- "AGENT",
- "AUTHSERVICE",
- "CONTAINER",
- "ERROR",
- "POLICY",
- "HTTP",
- "CONN_MGR",
- "PYTHON",
- "DEFAULT"
- ],
- "description": "Module to configure. The special module 'DEFAULT' specifies defaults for all modules."
- },
- "enable": {
- "type": "string",
- "description": "Levels are: trace, debug, info, notice, warning, error, critical. The enable string is a comma-separated list of levels. A level may have a trailing '\\+' to enable that level and above. For example 'trace,debug,warning+' means enable trace, debug, warning, error and critical. The value 'none' means disable logging for the module."
- },
- "includeSource": {
- "type": "boolean",
- "description": "Include source file and line number in log messages."
- },
- "includeTimestamp": {
- "type": "boolean",
- "description": "Include timestamp in log messages."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.log",
- "description": "Configure logging for a particular module. You can use the `UPDATE` operation to change log settings while the router is running."
- },
- "vhostUserGroupSettings": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "allowFallbackLinks": {
- "default": true,
- "type": "boolean",
- "description": "Whether this connection is allowed to claim 'qd.fallback' capability for attached links. This allows endpoints to act as fallback destinations for addresses that have fallback capability enabled."
- },
- "allowAnonymousSender": {
- "type": "boolean",
- "description": "Whether this connection is allowed to create sending links if the sender does not provide a target address. By prohibiting anonymous senders, the router only needs to verify once, when the link is created, that the sender is permitted to send messages to the target address. The router does not need to verify each message that is sent on the link. A value of 'true' means that users may send messages to any address. Allowing anonymous senders can also decrease [...]
- },
- "maxReceivers": {
- "default": 2147483647,
- "type": "integer",
- "description": "The maximum number of receiving links that may be created on this connection. A value of '0' disables all receiver links."
- },
- "users": {
- "required": true,
- "type": "string",
- "description": "A list of authenticated users for this user group. Use commas to separate multiple users. A user may belong to only one vhost user group."
- },
- "sourcePattern": {
- "type": "string",
- "description": "A wildcarded pattern for matching source addresses from which users in this group may receive messages. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match has the highest precedenc [...]
- },
- "allowWaypointLinks": {
- "default": true,
- "type": "boolean",
- "description": "Whether this connection is allowed to claim 'waypoint.N' capability for attached links. This allows endpoints to act as waypoints without needing auto-links."
- },
- "maxSessionWindow": {
- "default": 1638400,
- "type": "integer",
- "description": "The incoming capacity for new AMQP sessions, measured in octets. Non-zero policy values overwrite values specified for a listener object (AMQP Begin, incoming-window)."
- },
- "allowUserIdProxy": {
- "type": "boolean",
- "description": "Whether this connection is allowed to send messages with a user ID that is different than the connection's authenticated user name."
- },
- "maxFrameSize": {
- "default": 16384,
- "type": "integer",
- "description": "The largest frame, in bytes, that may be sent on this connection. Non-zero policy values overwrite values specified for a listener object (AMQP Open, max-frame-size)."
- },
- "targets": {
- "type": "string",
- "description": "A list of target addresses to which users in this group may send messages. To specify multiple addresses, separate the addresses with either a comma or a space. If you do not specify any addresses, users in this group are not allowed to send messages to any addresses. You can use the substitution token '${user}' to specify an address that contains a user's authenticated user name. You can use an asterisk ('*') wildcard to match one or more characters in an a [...]
- },
- "sources": {
- "type": "string",
- "description": "A list of source addresses from which users in this group may receive messages. To specify multiple addresses, separate the addresses with either a comma or a space. If you do not specify any addresses, users in this group are not allowed to receive messages from any addresses. You can use the substitution token '${user}' to specify an address that contains a user's authenticated user name. You can use an asterisk ('*') wildcard to match one or more characte [...]
- },
- "allowAdminStatusUpdate": {
- "default": true,
- "type": "boolean",
- "description": "Whether this connection is allowed to update the admin status of other connections. Note: Inter-router connections cannot be deleted at any time."
- },
- "allowDynamicLinkRoutes": {
- "default": true,
- "type": "boolean",
- "description": "Whether this connection is allowed to dynamically create connection-scoped link route destinations."
- },
- "allowDynamicSource": {
- "type": "boolean",
- "description": "Whether this connection is allowed to create dynamic receiving links (links to resources that do not exist on the peer). A value of 'true' means that users are able to automatically create resources on the peer system."
- },
- "remoteHosts": {
- "required": true,
- "type": "string",
- "description": "A list of remote hosts from which the users may connect. A host can be a hostname, IP address, or IP address range. Use commas to separate multiple hosts. To allow access from all remote hosts, specify a wildcard '*'. To deny access from all remote hosts, leave this attribute blank."
- },
- "maxSenders": {
- "default": 2147483647,
- "type": "integer",
- "description": "The maximum number of sending links that may be created on this connection. A value of '0' disables all sender links."
- },
- "targetPattern": {
- "type": "string",
- "description": "A wildcarded pattern for matching target addresses to which users in this group may send messages. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match has the highest precedence. To [...]
- },
- "maxSessions": {
- "default": 32768,
- "type": "integer",
- "description": "The maximum number of sessions that may be created on this connection. Non-zero policy values overwrite values specified for a listener object (AMQP Open, channel-max)."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.vhostUserGroupSettings",
- "description": "Policy settings for users connecting to a vhost. Configuration files including this section must use .json format."
- },
- "vhostStats": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "perHostState": {
- "type": "map",
- "description": "A map where the key is the host name and the value is a list of the host's connections."
- },
- "hostname": {
- "type": "string",
- "description": "The vhost name."
- },
- "perUserState": {
- "type": "map",
- "description": "A map where the key is the authenticated user name and the value is a list of the user's connections."
- },
- "sessionDenied": {
- "graph": true,
- "type": "integer"
- },
- "connectionsApproved": {
- "graph": true,
- "type": "integer"
- },
- "receiverDenied": {
- "graph": true,
- "type": "integer"
- },
- "connectionsCurrent": {
- "graph": true,
- "type": "integer"
- },
- "senderDenied": {
- "graph": true,
- "type": "integer"
- },
- "connectionsDenied": {
- "graph": true,
- "type": "integer"
- },
- "id": {
- "type": "string",
- "description": "The vhost name. DEPRECATED - use 'hostname' instead."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.vhostStats",
- "description": "Virtual host connection and access statistics."
- },
- "connector": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "stripAnnotations": {
- "default": "both",
- "type": [
- "in",
- "out",
- "both",
- "no"
- ],
- "description": "['in', 'out', 'both', 'no'] in: Strip the dispatch router specific annotations only on ingress; out: Strip the dispatch router specific annotations only on egress; both: Strip the dispatch router specific annotations on both ingress and egress; no - do not strip dispatch router specific annotations"
- },
- "saslUsername": {
- "type": "string",
- "description": "The user name that the connector is using to connect to a peer."
- },
- "allowRedirect": {
- "default": true,
- "type": "boolean",
- "description": "Allow the peer to redirect this connection to another address."
- },
- "idleTimeoutSeconds": {
- "default": 16,
- "type": "integer",
- "description": "The idle timeout, in seconds, for connections through this connector. If no frames are received on the connection for this time interval, the connection shall be closed."
- },
- "maxSessionFrames": {
- "type": "integer",
- "description": "Session incoming window measured in transfer frames for sessions created on this connection. This is the number of transfer frames that may simultaneously be in flight for all links in the session. Setting this value to zero selects the default session window size. Policy settings will not overwrite this value. The numerical product of maxFrameSize and maxSessionFrames may not exceed 2^31-1. If (maxFrameSize x maxSessionFrames) exceeds 2^31-1 then maxSession [...]
- },
- "cost": {
- "default": 1,
- "type": "integer",
- "description": "For the 'inter-router' role only. This value assigns a cost metric to the inter-router connection. The default (and minimum) value is one. Higher values represent higher costs. The cost is used to influence the routing algorithm as it attempts to use the path with the lowest total cost from ingress to egress."
- },
- "port": {
- "default": "amqp",
- "type": "string",
- "description": "Port number or symbolic service name."
- },
- "policyVhost": {
- "type": "string",
- "description": "A connector may optionally define a policy to restrict the remote container to access only specific resources. This attribute defines the name of the policy vhost for this connector. Within the vhost the connector will use the vhost policy settings from user group '$connector'. If the vhost policy is absent or if the user group '$connector' within that policy is absent then the connector will fail to start. In policy specified via connector attribute 'polic [...]
- },
- "saslMechanisms": {
- "type": "string",
- "description": "Space separated list of accepted SASL authentication mechanisms."
- },
- "linkCapacity": {
- "type": "integer",
- "description": "The capacity of links within this connection, in terms of message deliveries. The capacity is the number of messages that can be in-flight concurrently for each link."
- },
- "role": {
- "default": "normal",
- "type": [
- "normal",
- "inter-router",
- "route-container",
- "edge"
- ],
- "description": "The role of an established connection. In the normal role, the connection is assumed to be used for AMQP clients that are doing normal message delivery over the connection. In the inter-router role, the connection is assumed to be to another router in the network. Inter-router discovery and routing protocols can only be used over inter-router connections. route-container role can be used for router-container connections, for example, a router-broker connec [...]
- },
- "saslPassword": {
- "type": "string",
- "description": "The password that the connector is using to connect to a peer."
- },
- "maxSessions": {
- "default": 32768,
- "type": "integer",
- "description": "The maximum number of sessions that can be simultaneously active on the connection. Setting this value to zero selects the default number of sessions. Policy settings will not overwrite this value. Defaults to 32768."
- },
- "messageLoggingComponents": {
- "default": "none",
- "type": "string",
- "description": "A comma separated list that indicates which components of the message should be logged (no spaces allowed between list components). Defaults to 'none' (log nothing). If you want all properties and application properties of the message logged use 'all'. Specific components of the message can be logged by indicating the components via a comma separated list. The components are message-id, user-id, to, subject, reply-to, correlation-id, content-type, content-en [...]
- },
- "host": {
- "default": "127.0.0.1",
- "type": "string",
- "description": "IP address: ipv4 or ipv6 literal or a host name"
- },
- "protocolFamily": {
- "type": [
- "IPv4",
- "IPv6"
- ],
- "description": "['IPv4', 'IPv6'] IPv4: Internet Protocol version 4; IPv6: Internet Protocol version 6. If not specified, the protocol family will be automatically determined from the address."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "verifyHostname": {
- "default": true,
- "type": "boolean",
- "description": "yes: Ensures that when initiating a connection (as a client) the host name in the URL to which this connector connects to matches the host name in the digital certificate that the peer sends back as part of the SSL connection; no: Does not perform host name verification"
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "maxFrameSize": {
- "default": 16384,
- "type": "integer",
- "description": "The maximum frame size in octets that will be used in the connection-open negotiation with a connected peer. The frame size is the largest contiguous set of uninterrupted data that can be sent for a message delivery over the connection. Interleaving of messages on different links is done at frame granularity. Policy settings will not overwrite this value. Defaults to 16384."
- },
- "sslProfile": {
- "type": "string",
- "description": "Name of the sslProfile."
- },
- "failoverUrls": {
- "type": "string",
- "description": "A read-only, comma-separated list of failover urls. "
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.connector",
- "description": "Establishes an outgoing connection from the router."
- },
- "logStats": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "debugCount": {
- "graph": true,
- "type": "integer",
- "description": "How many debug-level events have happened on this log."
- },
- "criticalCount": {
- "graph": true,
- "type": "integer",
- "description": "How many critical-level events have happened on this log."
- },
- "traceCount": {
- "graph": true,
- "type": "integer",
- "description": "How many trace-level events have happened on this log."
- },
- "warningCount": {
- "graph": true,
- "type": "integer",
- "description": "How many warning-level events have happened on this log."
- },
- "infoCount": {
- "graph": true,
- "type": "integer",
- "description": "How many info-level events have happened on this log."
- },
- "noticeCount": {
- "graph": true,
- "type": "integer",
- "description": "How many notice-level events have happened on this log."
- },
- "errorCount": {
- "graph": true,
- "type": "integer",
- "description": "How many error-level events have happened on this log."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.logStats",
- "description": "histogram of the different severity-levels of events on the given log."
- },
- "configurationEntity": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.configurationEntity",
- "description": "Base type for entities containing configuration information."
- },
- "exchange": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "divertedCount": {
- "type": "integer",
- "description": "A count of those deliveries that were forwarded via the alternateAddress only. This is a subset of the forwardedCount."
- },
- "alternatePhase": {
- "type": "integer",
- "description": "The address phase for the alternateAddress. Defaults to '0'."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "matchMethod": {
- "default": "amqp",
- "type": [
- "amqp",
- "mqtt"
- ],
- "description": "Key matching algorithm used. 'amqp' uses the legacy AMQP topic exchange wildcard match method as described in the pre-1.0 drafts. 'mqtt' uses the MQTT topic filter wildcard match method."
- },
- "forwardedCount": {
- "type": "integer",
- "description": "The total number of deliveries forwarded via matched bindings or to the alternateAddress"
- },
- "receivedCount": {
- "type": "integer",
- "description": "The total number of deliveries received by this exchange."
- },
- "bindingCount": {
- "type": "integer",
- "description": "The number of bindings associated with this exchange."
- },
- "address": {
- "required": true,
- "type": "string",
- "description": "The address of the exchange. Used by the message publisher as the target for sending messages."
- },
- "phase": {
- "type": "integer",
- "description": "The address phase for the exchange. Defaults to '0'."
- },
- "alternateAddress": {
- "type": "string",
- "description": "The address to forward the message to if no bindings are matched."
- },
- "droppedCount": {
- "type": "integer",
- "description": "The total number of deliveries dropped due to the lack of an outgoing subscription."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.config.exchange",
- "description": "[EXPERIMENTAL] Defines a topic exchange."
- },
- "listener": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "stripAnnotations": {
- "default": "both",
- "type": [
- "in",
- "out",
- "both",
- "no"
- ],
- "description": "['in', 'out', 'both', 'no'] in: Strip the dispatch router specific annotations only on ingress; out: Strip the dispatch router specific annotations only on egress; both: Strip the dispatch router specific annotations on both ingress and egress; no - do not strip dispatch router specific annotations"
- },
- "requireSsl": {
- "type": "boolean",
- "description": "yes: Require the use of SSL or TLS on the connection; no: Allow clients to connect without SSL or TLS."
- },
- "idleTimeoutSeconds": {
- "default": 16,
- "type": "integer",
- "description": "The idle timeout, in seconds, for connections through this listener. If no frames are received on the connection for this time interval, the connection shall be closed."
- },
- "maxSessionFrames": {
- "type": "integer",
- "description": "Session incoming window measured in transfer frames for sessions created on this connection. This is the number of transfer frames that may simultaneously be in flight for all links in the session. Setting this value to zero selects the default session window size. Policy settings, if specified, will overwrite this value. The numerical product of maxFrameSize and maxSessionFrames may not exceed 2^31-1. If (maxFrameSize x maxSessionFrames) exceeds 2^31-1 then [...]
- },
- "cost": {
- "default": 1,
- "type": "integer",
- "description": "For the 'inter-router' role only. This value assigns a cost metric to the inter-router connection. The default (and minimum) value is one. Higher values represent higher costs. The cost is used to influence the routing algorithm as it attempts to use the path with the lowest total cost from ingress to egress."
- },
- "port": {
- "default": "amqp",
- "type": "string",
- "description": "Port number or symbolic service name. If '0', the router shall assign an ephemeral port to the listener and log the port number with a log of the form 'SERVER (notice) Listening on <host>:<assigned-port> (<listener-name>)'"
- },
- "saslPlugin": {
- "type": "string",
- "description": "EXPERIMENTAL. Name of the a sasl plugin configuration section to use for this listener (e.g. authServicePlugin)."
- },
- "linkCapacity": {
- "type": "integer",
- "description": "The capacity of links within this connection, in terms of message deliveries. The capacity is the number of messages that can be in-flight concurrently for each link."
- },
- "policyVhost": {
- "type": "string",
- "description": "A listener may optionally define a virtual host to index to a specific policy to restrict the remote container to access only specific resources. This attribute defines the name of the policy vhost for this listener. If multi-tenancy is enabled for the listener, this vhost will override the peer-supplied vhost for the purposes of identifying the desired policy settings for the connections."
- },
- "saslMechanisms": {
- "type": "string",
- "description": "Space separated list of accepted SASL authentication mechanisms."
- },
- "requireEncryption": {
- "type": "boolean",
- "description": "yes: Require the connection to the peer to be encrypted; no: Permit non-encrypted communication with the peer"
- },
- "trustedCertsFile": {
- "type": "path",
- "description": "This optional setting can be used to reduce the set of available CAs for client authentication. If used, this setting must provide the absolute path to a PEM file that contains the trusted certificates."
- },
- "role": {
- "default": "normal",
- "type": [
- "normal",
- "inter-router",
- "route-container",
- "edge"
- ],
- "description": "The role of an established connection. In the normal role, the connection is assumed to be used for AMQP clients that are doing normal message delivery over the connection. In the inter-router role, the connection is assumed to be to another router in the network. Inter-router discovery and routing protocols can only be used over inter-router connections. route-container role can be used for router-container connections, for example, a router-broker connec [...]
- },
- "websockets": {
- "default": true,
- "type": "boolean",
- "description": "For an http enabled listener, determines whether websockets access is enabled (true by default)."
- },
- "maxSessions": {
- "default": 32768,
- "type": "integer",
- "description": "The maximum number of sessions that can be simultaneously active on the connection. Setting this value to zero selects the default number of sessions. Policy settings, if specified, will overwrite this value. Defaults to 32768."
- },
- "authenticatePeer": {
- "type": "boolean",
- "description": "yes: Require the peer's identity to be authenticated; no: Do not require any authentication."
- },
- "http": {
- "type": "boolean",
- "description": "Accept HTTP connections that can upgrade to AMQP over WebSocket. Plain AMQP connections are not accepted on this listener."
- },
- "messageLoggingComponents": {
- "default": "none",
- "type": "string",
- "description": "A comma separated list that indicates which components of the message should be logged. Defaults to 'none' (log nothing). If you want all properties and application properties of the message logged use 'all'. Specific components of the message can be logged by indicating the components via a comma separated list. The components are message-id, user-id, to, subject, reply-to, correlation-id, content-type, content-encoding, absolute-expiry-time, creation-time, [...]
- },
- "multiTenant": {
- "type": "boolean",
- "description": "If true, apply multi-tenancy to endpoints connected at this listener. The address space is defined by the virtual host (hostname field in the Open)."
- },
- "metrics": {
- "default": true,
- "type": "boolean",
- "description": "Export metrics in prometheus text format for the router (using path /metrics). Assumes listener is enabled for http."
- },
- "host": {
- "type": "string",
- "description": "A host name, IPV4 or IPV6 literal, or the empty string. The empty string listens on all local addresses. A host name listens on all addresses associated with the name. An IPV6 literal address (or wildcard '[::]') listens only for IPV6. An IPV4 literal address (or wildcard '0.0.0.0') listens only for IPV4."
- },
- "initialHandshakeTimeoutSeconds": {
- "type": "integer",
- "description": "The timeout, in seconds, for the initial handshake for connections coming in through listeners. If the time interval expires before the peer sends the AMQP OPEN frame, the connection shall be closed. A value of zero (the default) disables this timeout."
- },
- "httpRootDir": {
- "type": "path",
- "description": "Absolute path to a directory from which to serve static HTML files. For example, /usr/share/qpid-dispatch/console."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "socketAddressFamily": {
- "type": [
- "IPv4",
- "IPv6"
- ],
- "description": "['IPv4', 'IPv6'] IPv4: Internet Protocol version 4; IPv6: Internet Protocol version 6. If not specified, the protocol family will be automatically determined from the address."
- },
- "healthz": {
- "default": true,
- "type": "boolean",
- "description": "Provide a simple HTTP based liveness test (using path /healthz). Assumes listener is enabled for http."
- },
- "maxFrameSize": {
- "default": 16384,
- "type": "integer",
- "description": "The maximum frame size in octets that will be used in the connection-open negotiation with a connected peer. The frame size is the largest contiguous set of uninterrupted data that can be sent for a message delivery over the connection. Interleaving of messages on different links is done at frame granularity. Policy settings, if specified, will overwrite this value. Defaults to 16384."
- },
- "sslProfile": {
- "type": "string",
- "description": "Name of the sslProfile."
- },
- "failoverUrls": {
- "type": "string",
- "description": "A comma-separated list of failover urls to be supplied to connected clients. Form: [(amqp|amqps|ws|wss)://]host_or_ip[:port]"
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.listener",
- "description": "Listens for incoming connections to the router."
- },
- "policy": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "enableVhostNamePatterns": {
- "type": "boolean",
- "description": "Enable vhost name patterns. When false vhost hostnames are treated as literal strings. When true vhost hostnames are treated as match patterns."
- },
- "connectionsProcessed": {
- "graph": true,
- "type": "integer"
- },
- "policyDir": {
- "type": "path",
- "description": "The absolute path to a directory that holds vhost policy definition files in JSON format (*.json). The router processes all of the vhost policies in each JSON file that is in this directory."
- },
- "defaultVhost": {
- "default": "$default",
- "type": "string",
- "description": "The name of the default vhost policy. This policy rule set is applied to a connection for which a vhost policy has not otherwise been configured. Processing for the default vhost is enabled by default and set to select vhost '$default'. To disable default vhost processing set defaultVhost to blank or do not define a vhost named '$default'."
- },
- "connectionsDenied": {
- "graph": true,
- "type": "integer"
- },
- "enableVhostPolicy": {
- "type": "boolean",
- "description": "Enables the router to enforce the connection denials and resource limits defined in the configured vhost policies."
- },
- "maxConnections": {
- "default": 65535,
- "type": "integer",
- "description": "The maximum number of concurrent client connections allowed for this router. This limit is always enforced, even if no other policy settings have been defined. The limit is applied to all incoming connections regardless of remote host, authenticated user, or targeted vhost."
- },
- "connectionsCurrent": {
- "graph": true,
- "type": "integer"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "singleton": true,
- "fullyQualifiedType": "org.apache.qpid.dispatch.policy",
- "description": "Defines global connection limit"
- },
- "address": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "egressPhase": {
- "type": "integer",
- "description": "Advanced - Override the egress phase for this address"
- },
- "pattern": {
- "type": "string",
- "description": "A wildcarded pattern for address matching. Incoming addresses are matched against this pattern. Matching addresses use the configured settings. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, a [...]
- },
- "ingressPhase": {
- "type": "integer",
- "description": "Advanced - Override the ingress phase for this address"
- },
- "priority": {
- "type": "integer",
- "description": "All messages sent to this address which lack an intrinsic priority will be assigned this priority."
- },
- "enableFallback": {
- "type": "boolean",
- "description": "If false, undeliverable messages are released. If true, undeliverable messages shall be re-delivered to a fallback destination. The fallback destination uses the same address, but is attached using an autoLink with 'fallback' enabled or a link with the qd.fallback capability."
- },
- "prefix": {
- "type": "string",
- "description": "The address prefix for the configured settings. Cannot be used with a pattern attribute."
- },
- "waypoint": {
- "type": "boolean",
- "description": "Designates this address space as being used for waypoints. This will cause the proper address-phasing to be used."
- },
- "distribution": {
- "default": "balanced",
- "type": [
- "multicast",
- "closest",
- "balanced",
- "unavailable"
- ],
- "description": "Treatment of traffic associated with the address"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.config.address",
- "description": "Entity type for address configuration. This is used to configure the treatment of message-routed deliveries within a particular address-space. The configuration controls distribution and address phasing."
- },
- "authServicePlugin": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "realm": {
- "type": "string",
- "description": "Value to set for hostname field on sasl-init"
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "host": {
- "type": "string",
- "description": "A host name, IPV4 or IPV6 literal, of the service to delegate to."
- },
- "sslProfile": {
- "type": "string",
- "description": "Name of the sslProfile to use for the authentication service."
- },
- "port": {
- "default": "amqp",
- "type": "string",
- "description": "Port number of the service delegated host."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.authServicePlugin",
- "description": "EXPERIMENTAL. Attributes for setting SASL plugin."
- },
- "router.node": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "routerLink": {
- "type": "entityId",
- "description": "Local link to remote node"
- },
- "nextHop": {
- "type": "string",
- "description": "Neighbour ID of next hop to remote node from here."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "index": {
- "type": "integer",
- "description": "Index number used in statistics histograms for this router node. This index is specific to this router."
- },
- "validOrigins": {
- "type": "list",
- "description": "List of valid origin nodes for messages arriving via the re mote node, used for duplicate elimination in redundant networks."
- },
- "linkState": {
- "type": "list",
- "description": "List of remote node's neighbours."
- },
- "instance": {
- "type": "integer",
- "description": "Remote node boot number."
- },
- "cost": {
- "type": "integer",
- "description": "Reachability cost"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "protocolVersion": {
- "type": "integer",
- "description": "Router-protocol version supported by the node."
- },
- "lastTopoChange": {
- "type": "integer",
- "description": "Timestamp showing the most recent change to this node's neighborhood."
- },
- "id": {
- "type": "string",
- "description": "Remote node identifier."
- },
- "address": {
- "type": "string",
- "description": "Address of the remote node"
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.node",
- "description": "Remote router node connected to this router."
- },
- "autoLink": {
- "operations": [
- "CREATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "operStatus": {
- "type": [
- "inactive",
- "attaching",
- "failed",
- "active",
- "quiescing",
- "idle"
- ],
- "description": "The operational status of this autoLink: inactive - The remote container is not connected; attaching - the link is attaching to the remote node; failed - the link attach failed; active - the link is attached and operational; quiescing - the link is transitioning to idle state; idle - the link is attached but there are no deliveries flowing and no unsettled deliveries."
- },
- "direction": {
- "required": true,
- "type": [
- "in",
- "out"
- ],
- "description": "The direction of the link to be created. In means into the router, out means out of the router."
- },
- "containerId": {
- "type": "string",
- "description": "ContainerID for the target container. Only one of containerId or connection should be specified for an autoLink. Specifying both will result in the autoLink not being created"
- },
- "linkRef": {
- "type": "string",
- "description": "Reference to the org.apache.qpid.dispatch.router.link if the link exists"
- },
- "externalAddress": {
- "type": "string",
- "description": "If present, an alternate address of the node on the remote container. This is used if the node has a different address than the address used internally by the router to route deliveries."
- },
- "connection": {
- "type": "string",
- "description": "The name from a connector or listener. Only one of containerId or connection should be specified for an autoLink. Specifying both will result in the autoLink not being created"
- },
- "address": {
- "required": true,
- "type": "string",
- "description": "The address of the provisioned object"
- },
- "phase": {
- "type": "integer",
- "description": "The address phase for this link. Defaults to '0' for 'out' links and '1' for 'in' links."
- },
- "fallback": {
- "type": "boolean",
- "description": "If true, this auto-link is attached to a fallback destination for an address."
- },
- "lastError": {
- "type": "string",
- "description": "The error description from the last attach failure"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.config.autoLink",
- "description": "Entity type for configuring auto-links. Auto-links are links whose lifecycle is managed by the router. These are typically used to attach to waypoints on remote containers (brokers, etc.)."
- },
- "router.address": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "subscriberCount": {
- "graph": true,
- "type": "integer",
- "description": "The number of local subscribers for this address (i.e. attached to this router)"
- },
- "deliveriesEgress": {
- "graph": true,
- "type": "integer",
- "description": "The number of deliveries to this address that exited the router network on this router"
- },
- "deliveriesEgressRouteContainer": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent to a route-container address."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "deliveriesIngress": {
- "graph": true,
- "type": "integer",
- "description": "The number of deliveries to this address that entered the router network on this router"
- },
- "transitOutstanding": {
- "type": "list",
- "description": "List of numbers of outstanding deliveries across a transit (inter-router) link for this address. This is for balanced distribution only."
- },
- "deliveriesIngressRouteContainer": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were received from a route-container address."
- },
- "priority": {
- "type": "integer",
- "description": "The message priority being handled by this address."
- },
- "remoteCount": {
- "graph": true,
- "type": "integer",
- "description": "The number of remote routers that have at least one subscriber to this address"
- },
- "inProcess": {
- "type": "integer",
- "description": "The number of in-process subscribers for this address"
- },
- "deliveriesFromContainer": {
- "graph": true,
- "type": "integer",
- "description": "The number of deliveries to this address that were originated from an in-process entity"
- },
- "deliveriesTransit": {
- "graph": true,
- "type": "integer",
- "description": "The number of deliveries to this address that transited this router to another router"
- },
- "containerCount": {
- "graph": true,
- "type": "integer",
- "description": "The number of attached containers that serve this route address"
- },
- "key": {
- "type": "string",
- "description": "Internal unique (to this router) key to identify the address"
- },
- "deliveriesRedirectedToFallback": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent to the fallback destination due to the primary destination being unreachable."
- },
- "distribution": {
- "type": [
- "flood",
- "multicast",
- "closest",
- "balanced",
- "linkBalanced",
- "unavailable"
- ],
- "description": "Forwarding treatment for the address: flood - messages delivered to all subscribers along all available paths (this will cause duplicate deliveries if there are redundant paths); multicast - one copy of each message delivered to all subscribers; closest - messages delivered to only the closest subscriber; balanced - messages delivered to one subscriber with load balanced across subscribers; linkBalanced - for link-routing, link attaches balanced across desti [...]
- },
- "trackedDeliveries": {
- "type": "integer",
- "description": "Number of transit deliveries being tracked for this address (for balanced distribution)."
- },
- "deliveriesToContainer": {
- "graph": true,
- "type": "integer",
- "description": "The number of deliveries to this address that were given to an in-process subscriber"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "remoteHostRouters": {
- "type": "list",
- "description": "List of remote routers on which there is a destination for this address."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.address",
- "description": "AMQP address managed by the router."
- },
- "router.link": {
- "operations": [
- "UPDATE",
- "READ"
- ],
- "attributes": {
- "adminStatus": {
- "default": "enabled",
- "type": [
- "enabled",
- "disabled"
- ]
- },
- "linkType": {
- "type": [
- "endpoint",
- "router-control",
- "inter-router"
- ],
- "description": "Type of link: endpoint: a link to a normally connected endpoint; inter-router: a link to another router in the network."
- },
- "unsettledCount": {
- "graph": true,
- "type": "integer",
- "description": "The number of unsettled deliveries awaiting settlement on the link"
- },
- "ingressHistogram": {
- "type": "list",
- "description": "For outgoing links on connections with 'normal' role. This histogram shows the number of settled deliveries on the link that ingressed the network at each interior router node."
- },
- "undeliveredCount": {
- "graph": true,
- "type": "integer",
- "description": "The number of undelivered messages pending for the link."
- },
- "acceptedCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of accepted deliveries."
- },
- "releasedCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of released deliveries."
- },
- "capacity": {
- "type": "integer",
- "description": "The capacity, in deliveries, for the link. The number of undelivered plus unsettled deliveries shall not exceed the capacity. This is enforced by link flow control."
- },
- "presettledCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of pre-settled deliveries."
- },
- "deliveriesDelayed1Sec": {
- "graph": true,
- "type": "integer",
- "description": "The total number of settled deliveries that were held in the router for 1 to 10 seconds."
- },
- "priority": {
- "type": "integer",
- "description": "For inter-router links, this is the message priority being handled."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "deliveriesDelayed10Sec": {
- "graph": true,
- "type": "integer",
- "description": "The total number of settled deliveries that were held in the router for more than 10 seconds."
- },
- "settleRate": {
- "graph": true,
- "type": "integer",
- "description": "The average rate (over five seconds) of settlement in deliveries-per-second. This is included for egress links only."
- },
- "droppedPresettledCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of pre-settled deliveries that were dropped."
- },
- "peer": {
- "type": "string",
- "description": "Identifier of the paired link if this is an attach-routed link."
- },
- "linkName": {
- "type": "string",
- "description": "Name assigned to the link in the Attach."
- },
- "rejectedCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of rejected deliveries."
- },
- "deliveryCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of deliveries that have traversed this link."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "operStatus": {
- "type": [
- "up",
- "down",
- "quiescing",
- "idle"
- ]
- },
- "linkDir": {
- "type": [
- "in",
- "out"
- ],
- "description": "Direction of delivery flow over the link, inbound or outbound to or from the router."
- },
- "modifiedCount": {
- "graph": true,
- "type": "integer",
- "description": "The total number of modified deliveries."
- },
- "owningAddr": {
- "type": "string",
- "description": "Address assigned to this link during attach: The target for inbound links or the source for outbound links."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.router.link",
- "description": "Link to another AMQP endpoint: router node, client or other AMQP process."
- },
- "org.amqp.management": {
- "operations": [
- "QUERY",
- "GET-TYPES",
- "GET-ANNOTATIONS",
- "GET-OPERATIONS",
- "GET-ATTRIBUTES",
- "GET-MGMT-NODES",
- "READ"
- ],
- "attributes": {
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.org.amqp.management",
- "description": "The standard AMQP management node interface."
- },
- "operationalEntity": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.operationalEntity",
- "description": "Base type for entities containing current operational information."
- },
- "connection": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "adminStatus": {
- "default": "enabled",
- "type": [
- "enabled",
- "deleted"
- ],
- "description": "This field is set to enabled when the connection is up and running. Setting this field to deleted will terminate the connection and all links and sessions contained in the connection. Inter-router connections cannot be terminated by setting the adminStatus to deleted."
- },
- "container": {
- "type": "string",
- "description": "The container for this connection"
- },
- "opened": {
- "type": "boolean",
- "description": "The connection has been opened (i.e. AMQP OPEN)"
- },
- "sslCipher": {
- "type": "string",
- "description": "SSL cipher name"
- },
- "operStatus": {
- "type": [
- "up",
- "closing"
- ]
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "sslProto": {
- "type": "string",
- "description": "SSL protocol name"
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "properties": {
- "type": "map",
- "description": "Connection properties supplied by the peer."
- },
- "ssl": {
- "type": "boolean",
- "description": "True iff SSL/TLS is in effect for this connection."
- },
- "host": {
- "type": "string",
- "description": "IP address and port number in the form addr:port."
- },
- "isEncrypted": {
- "type": "boolean",
- "description": "Indicates whether the connection content is encrypted."
- },
- "role": {
- "type": "string"
- },
- "isAuthenticated": {
- "type": "boolean",
- "description": "Indicates whether the identity of the connection's user is authentic."
- },
- "tenant": {
- "type": "string",
- "description": "If multi-tenancy is on for this connection, the tenant space in effect"
- },
- "sasl": {
- "type": "string",
- "description": "SASL mechanism in effect for authentication."
- },
- "sslSsf": {
- "type": "integer",
- "description": "SSL strength factor in effect"
- },
- "dir": {
- "type": [
- "in",
- "out"
- ],
- "description": "Direction of connection establishment in or out of the router."
- },
- "user": {
- "type": "string",
- "description": "Identity of the authenticated user."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.connection",
- "description": "Connections to the router's container."
- },
- "router": {
- "operations": [
- "READ"
- ],
- "attributes": {
- "workerThreads": {
- "default": 4,
- "type": "integer",
- "description": "The number of threads that will be created to process message traffic and other application work (timers, non-amqp file descriptors, etc.) ."
- },
- "raIntervalSeconds": {
- "default": 30,
- "type": "integer",
- "description": "Interval in seconds between Router-Advertisements sent to all routers in a stable network."
- },
- "raIntervalFluxSeconds": {
- "default": 4,
- "type": "integer",
- "description": "Interval in seconds between Router-Advertisements sent to all routers during topology fluctuations."
- },
- "linkRouteCount": {
- "graph": true,
- "type": "integer",
- "description": "Number of link routes attached to the router node."
- },
- "allowResumableLinkRoute": {
- "default": true,
- "type": "boolean",
- "description": "Whether links can be routed where timeout is non-zero or expiry-policy is not link-detach"
- },
- "rejectedDeliveries": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries whose delivery state was set to REJECTED by the router. These deliveries were Invalid and unprocessable."
- },
- "autoLinkCount": {
- "graph": true,
- "type": "integer",
- "description": "Number of auto links attached to the router node."
- },
- "saslConfigName": {
- "default": "qdrouterd",
- "type": "string",
- "description": "Name of the SASL configuration. This string + '.conf' is the name of the configuration file."
- },
- "id": {
- "type": "string",
- "description": "Router's unique identity. If not specified, a random identity will be assigned at startup."
- },
- "presettledDeliveries": {
- "graph": true,
- "type": "integer",
- "description": "Number of presettled deliveries handled by the router."
- },
- "deliveriesTransit": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent to another router in the network."
- },
- "area": {
- "type": "string",
- "description": "Unused placeholder."
- },
- "deliveriesIngress": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent to it by a sender that is directly attached to the router."
- },
- "deliveriesIngressRouteContainer": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were received from router container connections."
- },
- "droppedPresettledDeliveries": {
- "graph": true,
- "type": "integer",
- "description": "Number of presettled deliveries that were dropped by the router."
- },
- "acceptedDeliveries": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries whose delivery state was set to ACCEPTED by the router. These deliveries were successfully processed by the router."
- },
- "helloIntervalSeconds": {
- "default": 1,
- "type": "integer",
- "description": "Interval in seconds between HELLO messages sent to neighbor routers."
- },
- "deliveriesDelayed1Sec": {
- "graph": true,
- "type": "integer",
- "description": "The total number of settled deliveries that were held in the router for 1 to 10 seconds."
- },
- "saslConfigDir": {
- "type": "path",
- "description": "Absolute path to the SASL configuration file."
- },
- "version": {
- "type": "string",
- "description": "Software Version"
- },
- "remoteLsMaxAgeSeconds": {
- "default": 60,
- "type": "integer",
- "description": "Time in seconds after which link state is declared stale if no RA is received."
- },
- "deliveriesDelayed10Sec": {
- "graph": true,
- "type": "integer",
- "description": "The total number of settled deliveries that were held in the router for more than 10 seconds."
- },
- "linkCount": {
- "graph": true,
- "type": "integer",
- "description": "Number of links attached to the router node."
- },
- "debugDumpFile": {
- "type": "path",
- "description": "The absolute path to the location for the debug dump file. The router writes debug-level information to this file if the logger is not available."
- },
- "connectionCount": {
- "graph": true,
- "type": "integer",
- "description": "Number of open connections to the router node."
- },
- "hostName": {
- "type": "string",
- "description": "hostName of machine on which router is running"
- },
- "addrCount": {
- "graph": true,
- "type": "integer",
- "description": "Number of addresses known to the router."
- },
- "deliveriesEgressRouteContainer": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent to route container connections."
- },
- "nodeCount": {
- "graph": true,
- "type": "integer",
- "description": "Number of known peer router nodes."
- },
- "modifiedDeliveries": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries whose delivery state was set to MODIFIED by the router. These deliveries were modified but not processed."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "deliveriesEgress": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent by the router to a receiver that is directly attached to the router."
- },
- "releasedDeliveries": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries whose delivery state was set to RELEASED by the router. These deliveries was not (and will not be) processed"
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- },
- "timestampsInUTC": {
- "type": "boolean",
- "description": "Use UTC time rather than localtime in logs."
- },
- "timestampFormat": {
- "type": "string",
- "description": "Format string to use for timestamps in logs."
- },
- "helloMaxAgeSeconds": {
- "default": 3,
- "type": "integer",
- "description": "Time in seconds after which a neighbor is declared lost if no HELLO is received."
- },
- "defaultDistribution": {
- "default": "balanced",
- "type": [
- "multicast",
- "closest",
- "balanced",
- "unavailable"
- ],
- "description": "Default forwarding treatment for any address without a specified treatment. multicast - one copy of each message delivered to all subscribers; closest - messages delivered to only the closest subscriber; balanced - messages delivered to one subscriber with load balanced across subscribers; unavailable - this address is unavailable, link attaches to an address of unavilable distribution will be rejected."
- },
- "mode": {
- "default": "standalone",
- "type": [
- "standalone",
- "interior",
- "edge"
- ],
- "description": "In standalone mode, the router operates as a single component. It does not participate in the routing protocol and therefore will not cooperate with other routers. In interior mode, the router operates in cooperation with other interior routers in an interconnected network. In edge mode, the router can make a connection to an interior router and join a network without causing that network to recompute paths."
- },
- "deliveriesRedirectedToFallback": {
- "graph": true,
- "type": "integer",
- "description": "Number of deliveries that were sent to the fallback destination due to the primary destination being unreachable."
- },
- "allowUnsettledMulticast": {
- "type": "boolean",
- "description": "(DEPRECATED) If true, allow senders to send unsettled deliveries to multicast addresses. These deliveries shall be settled by the ingress router. If false, unsettled deliveries to multicast addresses shall be rejected."
- }
- },
- "singleton": true,
- "fullyQualifiedType": "org.apache.qpid.dispatch.router",
- "description": "Tracks peer routers and computes routes to destinations. This entity is mandatory. The router will not start without this entity."
- },
- "vhost": {
- "operations": [
- "CREATE",
- "UPDATE",
- "DELETE",
- "READ"
- ],
- "attributes": {
- "allowUnknownUser": {
- "type": "boolean",
- "description": "Whether unknown users (users who are not members of a defined user group) are allowed to connect to the vhost. Unknown users are assigned to the '$default' user group and receive '$default' settings."
- },
- "maxConnectionsPerUser": {
- "default": 65535,
- "type": "integer",
- "description": "The maximum number of concurrent client connections allowed for any user."
- },
- "hostname": {
- "required": true,
- "type": "string",
- "description": "The hostname of the vhost. This vhost policy will be applied to any client connection that is directed to this hostname."
- },
- "groups": {
- "type": "map",
- "description": "A map where each key is a vhost name and each value is a map of the settings for users of that vhost."
- },
- "maxConnections": {
- "default": 65535,
- "type": "integer",
- "description": "The global maximum number of concurrent client connections allowed for this vhost."
- },
- "maxConnectionsPerHost": {
- "default": 65535,
- "type": "integer",
- "description": "The maximum number of concurrent client connections allowed for any remote host (the host from which the client is connecting)."
- },
- "identity": {
- "unique": true,
- "type": "string",
- "description": "Unique identity generated by the system. Will not change."
- },
- "name": {
- "unique": true,
- "type": "string",
- "description": "Unique name optionally assigned by user. Can be changed."
- }
- },
- "fullyQualifiedType": "org.apache.qpid.dispatch.vhost",
- "description": "AMQP virtual host policy definition of users, user groups, allowed remote hosts, and AMQP restrictions."
- }
- }
- },
- setHooks: () => { }
- }
-}
+ schema,
+ setHooks: () => {}
+ };
+};
diff --git a/console/react/src/topology/clientInfoComponent.js b/console/react/src/topology/clientInfoComponent.js
index 8ef3dad..b05462b 100644
--- a/console/react/src/topology/clientInfoComponent.js
+++ b/console/react/src/topology/clientInfoComponent.js
@@ -80,10 +80,7 @@ class ClientInfoComponent extends Component {
cells: [
{
title: (
- <DetailsTable
- rows={[1, 2, 3, 4, 5, 6]}
- id="compound-expansion-table-1"
- />
+ <DetailsTable rows={[1, 2, 3, 4, 5, 6]} id="compound-expansion-table-1" />
),
props: { colSpan: 4, className: "pf-m-no-padding" }
}
@@ -130,14 +127,7 @@ class ClientInfoComponent extends Component {
"unsettledCount",
"capacity"
],
- cols: [
- "linkType",
- "addr",
- "settleRate",
- "delayed1",
- "delayed10",
- "usage"
- ],
+ cols: ["linkType", "addr", "settleRate", "delayed1", "delayed10", "usage"],
calc: {
addr: link => {
return utils.addr_text(link.owningAddr);
@@ -207,9 +197,7 @@ class ClientInfoComponent extends Component {
results => {
// save the results for each entity requested
if (infoPerId[id]) {
- infoPerId[id].linkRoutes = utils.flattenAll(
- results[nodeId].linkRoute
- );
+ infoPerId[id].linkRoutes = utils.flattenAll(results[nodeId].linkRoute);
infoPerId[id].autoLinks = utils.flattenAll(results[nodeId].autoLink);
infoPerId[id].addresses = utils.flattenAll(results[nodeId].address);
}
@@ -227,10 +215,7 @@ class ClientInfoComponent extends Component {
[{ entity: "router", attrs: [] }],
results => {
let r = results[nodeId].router;
- infoPerId[n.container] = utils.flatten(
- r.attributeNames,
- r.results[0]
- );
+ infoPerId[n.container] = utils.flatten(r.attributeNames, r.results[0]);
let rates = utils.rates(
infoPerId[n.container],
["acceptedDeliveries"],
@@ -313,11 +298,7 @@ class ClientInfoComponent extends Component {
let count = this.d.normals.length;
let verb = count > 1 ? "are" : "is";
let preposition =
- this.d.cdir === "in"
- ? "to"
- : this.d.cdir === "both"
- ? "for"
- : "from";
+ this.d.cdir === "in" ? "to" : this.d.cdir === "both" ? "for" : "from";
let plural = count > 1 ? "s" : "";
this.setState({
detail: { template: "clients", title: "client" }
@@ -423,56 +404,6 @@ class ClientInfoComponent extends Component {
return newRows;
};
- /*
- {
- isOpen: false,
- cells: [
- {
- title: <span>container</span>,
- props: { component: "th" }
- },
- {
- title: <span>False</span>
- },
- {
- title: <span>host</span>
- },
- {
- title: (
- <React.Fragment>
- <CodeBranchIcon key="icon" /> 1
- </React.Fragment>
- ),
- props: {
- isOpen: false,
- ariaControls: "compound-expansion-table-1"
- }
- }
- ]
- },
- {
- parent: 0,
- compoundParent: 3,
- cells: [
- {
- title: (
- <DetailsTable
- firstColumnRows={[
- "parent-0",
- "compound-1",
- "three",
- "four",
- "five"
- ]}
- id="compound-expansion-table-1"
- />
- ),
- props: { colSpan: 4, className: "pf-m-no-padding" }
- }
- ]
- }
-*/
-
onExpand = (event, rowIndex, colIndex, isOpen, rowData, extraData) => {
const { rows } = this.state;
if (!isOpen) {
@@ -511,6 +442,7 @@ class ClientInfoComponent extends Component {
borders={false}
rows={rows}
cells={columns}
+ aria-label="client-info-table"
>
<TableHeader />
<TableBody />
diff --git a/console/react/src/topology/clientInfoDetailsComponent.jsx b/console/react/src/topology/clientInfoDetailsComponent.jsx
index 327b118..478467b 100644
--- a/console/react/src/topology/clientInfoDetailsComponent.jsx
+++ b/console/react/src/topology/clientInfoDetailsComponent.jsx
@@ -5,14 +5,7 @@ class DetailsTable extends React.Component {
constructor(props) {
super(props);
this.state = {
- columns: [
- "Link type",
- "Addr",
- "Settle rate",
- "Delayed1",
- "Delayed10",
- "Usage"
- ]
+ columns: ["Link type", "Addr", "Settle rate", "Delayed1", "Delayed10", "Usage"]
};
}
@@ -20,7 +13,7 @@ class DetailsTable extends React.Component {
const { columns } = this.state;
let subRows = this.props.subRows || [];
return (
- <Table cells={columns} rows={subRows}>
+ <Table aria-label="client-info-details-table" cells={columns} rows={subRows}>
<TableHeader />
<TableBody />
</Table>
diff --git a/console/react/src/topology/map.js b/console/react/src/topology/map.js
index 592b8a3..0e412e4 100644
--- a/console/react/src/topology/map.js
+++ b/console/react/src/topology/map.js
@@ -186,28 +186,31 @@ export class BackgroundMap {
this.svg.call(this.zoom).on("dblclick.zoom", null);
}
- // async load of data file. calls resolve when this completes to let caller know
- d3.json("data/countries.json", (error, world) => {
- if (error) reject(error);
- this.geo
- .append("path")
- .datum(topojson.feature(world, world.objects.countries))
- .attr("class", "land")
- .attr("d", this.geoPath)
- .style("stroke", d3.rgb(this.mapOptions.areaColor).darker());
-
- this.updateLandColor(this.mapOptions.areaColor);
- this.updateOceanColor(this.mapOptions.oceanColor);
-
- // restore map rotate, scale, translate
- this.restoreState();
-
- // draw with current positions
- this.geo.selectAll(".land").attr("d", this.geoPath);
-
- this.initialized = true;
- resolve();
- });
+ fetch("data/countries.json")
+ .then(res => res.json())
+ .then(world => {
+ this.geo
+ .append("path")
+ .datum(topojson.feature(world, world.objects.countries))
+ .attr("class", "land")
+ .attr("d", this.geoPath)
+ .style("stroke", d3.rgb(this.mapOptions.areaColor).darker());
+
+ this.updateLandColor(this.mapOptions.areaColor);
+ this.updateOceanColor(this.mapOptions.oceanColor);
+
+ // restore map rotate, scale, translate
+ this.restoreState();
+
+ // draw with current positions
+ this.geo.selectAll(".land").attr("d", this.geoPath);
+
+ this.initialized = true;
+ resolve();
+ })
+ .catch(error => {
+ reject(error);
+ });
});
}
@@ -293,8 +296,7 @@ export class BackgroundMap {
var bnorth = getMapBounds(this.projection, maxnorth),
bsouth = getMapBounds(this.projection, maxsouth);
if (bnorth[0][1] + dy > 0) dy = -bnorth[0][1];
- else if (bsouth[1][1] + dy < this.height)
- dy = this.height - bsouth[1][1];
+ else if (bsouth[1][1] + dy < this.height) dy = this.height - bsouth[1][1];
this.projection.translate([tp[0], tp[1] + dy]);
}
this.last.scale = scale;
diff --git a/console/react/src/topology/nodes.js b/console/react/src/topology/nodes.js
index 96729d5..dcad31c 100644
--- a/console/react/src/topology/nodes.js
+++ b/console/react/src/topology/nodes.js
@@ -51,12 +51,10 @@ export class Node {
}
title(hide) {
let x = "";
- if (this.normals && this.normals.length > 1 && !hide)
- x = " x " + this.normals.length;
+ if (this.normals && this.normals.length > 1 && !hide) x = " x " + this.normals.length;
if (this.isConsole) return "Dispatch console" + x;
else if (this.isArtemis) return "Broker - Artemis" + x;
- else if (this.properties.product === "qpid-cpp")
- return "Broker - qpid-cpp" + x;
+ else if (this.properties.product === "qpid-cpp") return "Broker - qpid-cpp" + x;
else if (this.nodeType === "edge") return "Edge Router";
else if (this.cdir === "in") return "Sender" + x;
else if (this.cdir === "out") return "Receiver" + x;
@@ -71,11 +69,11 @@ export class Node {
}
toolTip(topology, verbose) {
return new Promise(
- function (resolve) {
+ function(resolve) {
if (this.nodeType === "normal" || this.nodeType === "edge") {
resolve(this.clientTooltip());
} else
- this.routerTooltip(topology, verbose).then(function (toolTip) {
+ this.routerTooltip(topology, verbose).then(function(toolTip) {
resolve(toolTip);
});
}.bind(this)
@@ -99,7 +97,7 @@ export class Node {
routerTooltip(topology, verbose) {
return new Promise(
- function (resolve) {
+ function(resolve) {
topology.ensureEntities(
this.key,
[
@@ -111,7 +109,7 @@ export class Node {
entity: "router"
}
],
- function (foo, nodes) {
+ function(foo, nodes) {
// update all the router title text
let node = nodes[this.key];
const err = `<table class="popupTable"><tr><td>Error</td><td>Unable to get router info for ${this.key}</td></tr></table>`;
@@ -142,24 +140,15 @@ export class Node {
}
}
if (ports.length > 0) {
- title +=
- "<tr><td>Ports</td><td>" + ports.join(", ") + "</td></tr>";
+ title += "<tr><td>Ports</td><td>" + ports.join(", ") + "</td></tr>";
}
// add verbose rows
if (verbose) {
- title +=
- "<tr><td>Addresses</td><td>" + r.addrCount + "</td></tr>";
- title +=
- "<tr><td>Connections</td><td>" +
- r.connectionCount +
- "</td></tr>";
+ title += "<tr><td>Addresses</td><td>" + r.addrCount + "</td></tr>";
+ title += "<tr><td>Connections</td><td>" + r.connectionCount + "</td></tr>";
title += "<tr><td>Links</td><td>" + r.linkCount + "</td></tr>";
- title +=
- "<tr><td>Auto links</td><td>" + r.autoLinkCount + "</td></tr>";
- title +=
- "<tr><td>Link routes</td><td>" +
- r.linkRouteCount +
- "</td></tr>";
+ title += "<tr><td>Auto links</td><td>" + r.autoLinkCount + "</td></tr>";
+ title += "<tr><td>Link routes</td><td>" + r.linkRouteCount + "</td></tr>";
}
title += "</table>";
resolve(title);
@@ -302,7 +291,7 @@ export class Nodes {
return null;
}
nodeExists(connectionContainer) {
- return this.nodes.findIndex(function (node) {
+ return this.nodes.findIndex(function(node) {
return node.container === connectionContainer;
});
}
@@ -332,7 +321,7 @@ export class Nodes {
if (Object.prototype.toString.call(nodes) !== "[object Array]") {
nodes = [nodes];
}
- this.nodes.forEach(function (d) {
+ this.nodes.forEach(function(d) {
localStorage[d.name] = JSON.stringify({
x: Math.round(d.x),
y: Math.round(d.y),
@@ -466,18 +455,13 @@ export class Nodes {
for (let id in nodeInfo) {
let name = utils.nameFromId(id);
// if we have any new nodes, animate the force graph to position them
- let position = localStorage[name]
- ? JSON.parse(localStorage[name])
- : undefined;
+ let position = localStorage[name] ? JSON.parse(localStorage[name]) : undefined;
if (!position) {
animate = true;
position = {
- x: Math.round(
- width / 4 + (width / 2 / nodeCount) * this.nodes.length
- ),
+ x: Math.round(width / 4 + (width / 2 / nodeCount) * this.nodes.length),
y: Math.round(
- height / 2 +
- (Math.sin(this.nodes.length / (Math.PI * 2.0)) * height) / 4
+ height / 2 + (Math.sin(this.nodes.length / (Math.PI * 2.0)) * height) / 4
),
fixed: false
};
diff --git a/console/react/src/topology/svgUtils.js b/console/react/src/topology/svgUtils.js
index f0dae10..873a0c4 100644
--- a/console/react/src/topology/svgUtils.js
+++ b/console/react/src/topology/svgUtils.js
@@ -51,6 +51,9 @@ export function appendCircle(g) {
}
return null;
})
+ .attr("data-testid", function(d) {
+ return (d.nodeType !== "normal" ? "router" : "client") + "-" + d.index;
+ })
.classed("normal", function(d) {
return d.nodeType === "normal" || utils.isConsole(d);
})
@@ -83,9 +86,7 @@ export function appendCircle(g) {
})
.classed("route-container", function(d) {
return (
- !utils.isArtemis(d) &&
- !utils.isQpid(d) &&
- d.nodeType === "route-container"
+ !utils.isArtemis(d) && !utils.isQpid(d) && d.nodeType === "route-container"
);
})
.classed("client", function(d) {
@@ -137,9 +138,7 @@ export function appendContent(g) {
} else if (utils.isQpid(d)) {
return "\ue901"; // custom font character
} else if (d.nodeType === "route-container") {
- return d.properties.product
- ? d.properties.product[0].toUpperCase()
- : "S";
+ return d.properties.product ? d.properties.product[0].toUpperCase() : "S";
} else if (d.nodeType === "normal") {
return "\uf109"; // icon-laptop for clients
} else if (d.nodeType === "edge" || d.nodeType === "_edge") {
@@ -195,9 +194,7 @@ export function addDefs(svg) {
.attr("orient", "auto")
.append("svg:path")
.attr("d", function(d) {
- return d.sten === "end"
- ? "M 0 -5 L 10 0 L 0 5 z"
- : "M 10 -5 L 0 0 L 10 5 z";
+ return d.sten === "end" ? "M 0 -5 L 10 0 L 0 5 z" : "M 10 -5 L 0 0 L 10 5 z";
});
addStyles(
sten,
diff --git a/console/react/src/topology/topologyPage.js b/console/react/src/topology/topologyPage.js
index f2af09e..56f2df9 100644
--- a/console/react/src/topology/topologyPage.js
+++ b/console/react/src/topology/topologyPage.js
@@ -31,7 +31,11 @@ class TopologyPage extends Component {
render() {
return (
- <PageSection variant={PageSectionVariants.light} id="topologyPage">
+ <PageSection
+ data-testid="topology-page"
+ variant={PageSectionVariants.light}
+ id="topologyPage"
+ >
<TopologyViewer service={this.props.service} />
</PageSection>
);
diff --git a/console/react/src/topology/topologyPage.test.js b/console/react/src/topology/topologyPage.test.js
new file mode 100644
index 0000000..2b99aed
--- /dev/null
+++ b/console/react/src/topology/topologyPage.test.js
@@ -0,0 +1,14 @@
+import React from "react";
+import { render } from "@testing-library/react";
+import { mockService } from "../qdrService.mock";
+import TopologyPage from "./topologyPage";
+
+it("renders the TopologyPage component", () => {
+ const props = {
+ service: mockService({})
+ };
+ const { getByTestId } = render(<TopologyPage {...props} />);
+
+ // make sure it rendered the component
+ expect(getByTestId("topology-page")).toBeInTheDocument();
+});
diff --git a/console/react/src/topology/topologyViewer.js b/console/react/src/topology/topologyViewer.js
index e858426..9d7a0af 100644
--- a/console/react/src/topology/topologyViewer.js
+++ b/console/react/src/topology/topologyViewer.js
@@ -58,26 +58,26 @@ class TopologyPage extends Component {
savedOptions = savedOptions
? JSON.parse(savedOptions)
: {
- traffic: {
- open: false,
- dots: false,
- congestion: false,
- addresses: [],
- addressColors: []
- },
- legend: {
- open: true
- },
- map: {
- open: false,
- show: false
- },
- arrows: {
- open: false,
- routerArrows: false,
- clientArrows: true
- }
- };
+ traffic: {
+ open: false,
+ dots: false,
+ congestion: false,
+ addresses: [],
+ addressColors: []
+ },
+ legend: {
+ open: true
+ },
+ map: {
+ open: false,
+ show: false
+ },
+ arrows: {
+ open: false,
+ routerArrows: false,
+ clientArrows: true
+ }
+ };
// previous version read from storage didn't have show attribute
if (typeof savedOptions.map.show === "undefined") {
savedOptions.map.show = false;
@@ -142,10 +142,7 @@ class TopologyPage extends Component {
// get notified when a router is added/dropped and when
// the number of connections for a router changes
- this.props.service.management.topology.addChangedAction(
- "topology",
- this.init
- );
+ this.props.service.management.topology.addChangedAction("topology", this.init);
};
componentWillUnmount = () => {
@@ -174,7 +171,7 @@ class TopologyPage extends Component {
setSelected = (item, data) => {
// remove the selected attr from each node
- this.circle.each(function (d) {
+ this.circle.each(function(d) {
d.selected = false;
});
// set the selected attr for this node
@@ -186,7 +183,7 @@ class TopologyPage extends Component {
updateLegend = () => {
this.legend.update();
};
- clearPopups = () => { };
+ clearPopups = () => {};
// initialize the nodes and links array from the QDRService.topology._nodeInfo object
init = () => {
@@ -218,12 +215,10 @@ class TopologyPage extends Component {
.attr("aria-label", "topology-svg")
.on("click", this.clearPopups);
// read the map data from the data file and build the map layer
- this.backgroundMap
- .init(this, this.svg, this.width, this.height)
- .then(() => {
- this.forceData.nodes.saveLonLat(this.backgroundMap);
- this.backgroundMap.setMapOpacity(this.state.legendOptions.map.show);
- });
+ this.backgroundMap.init(this, this.svg, this.width, this.height).then(() => {
+ this.forceData.nodes.saveLonLat(this.backgroundMap);
+ this.backgroundMap.setMapOpacity(this.state.legendOptions.map.show);
+ });
addDefs(this.svg);
addGradient(this.svg);
}
@@ -255,12 +250,7 @@ class TopologyPage extends Component {
this.mousedown_node = null;
// initialize the list of nodes
- this.forceData.nodes.initialize(
- nodeInfo,
- this.width,
- this.height,
- localStorage
- );
+ this.forceData.nodes.initialize(nodeInfo, this.width, this.height, localStorage);
this.forceData.nodes.savePositions();
// initialize the list of links
@@ -307,7 +297,7 @@ class TopologyPage extends Component {
this.updateLegend();
if (this.oldSelectedNode) {
- d3.selectAll("circle.inter-router").classed("selected", function (d) {
+ d3.selectAll("circle.inter-router").classed("selected", function(d) {
if (d.key === this.oldSelectedNode.key) {
this.selected_node = d;
return true;
@@ -316,7 +306,7 @@ class TopologyPage extends Component {
});
}
if (this.oldMouseoverNode && this.selected_node) {
- d3.selectAll("circle.inter-router").each(function (d) {
+ d3.selectAll("circle.inter-router").each(function(d) {
if (d.key === this.oldMouseoverNode.key) {
this.mouseover_node = d;
this.props.service.management.topology.ensureAllEntities(
@@ -326,7 +316,7 @@ class TopologyPage extends Component {
attrs: ["id", "nextHop"]
}
],
- function () {
+ function() {
this.nextHopHighlight(this.selected_node, d);
this.restart();
}
@@ -335,10 +325,9 @@ class TopologyPage extends Component {
});
}
// if any clients don't yet have link directions, get the links for those nodes and restart the graph
- if (unknowns.length > 0)
- setTimeout(this.resolveUnknowns, 10, nodeInfo, unknowns);
+ if (unknowns.length > 0) setTimeout(this.resolveUnknowns, 10, nodeInfo, unknowns);
- var continueForce = function (extra) {
+ var continueForce = function(extra) {
if (extra > 0) {
--extra;
this.force.start();
@@ -372,12 +361,7 @@ class TopologyPage extends Component {
],
() => {
let nodeInfo = this.props.service.management.topology.nodeInfo();
- this.forceData.nodes.initialize(
- nodeInfo,
- this.width,
- this.height,
- localStorage
- );
+ this.forceData.nodes.initialize(nodeInfo, this.width, this.height, localStorage);
let edgeUnknowns = [];
this.forceData.links.initialize(
nodeInfo,
@@ -406,9 +390,7 @@ class TopologyPage extends Component {
handleMouseOutPath = d => {
// mouse out of a path
this.popupCancelled = true;
- this.props.service.management.topology.delUpdatedAction(
- "connectionPopupHTML"
- );
+ this.props.service.management.topology.delUpdatedAction("connectionPopupHTML");
this.setState({ showPopup: false });
d.selected = false;
connectionPopupHTML();
@@ -495,7 +477,7 @@ class TopologyPage extends Component {
enterpath
.append("path")
.attr("class", "link")
- .attr("id", function (d) {
+ .attr("id", function(d) {
const si = d.source.uid();
const ti = d.target.uid();
return ["path", si, ti].join("-");
@@ -531,7 +513,7 @@ class TopologyPage extends Component {
this.circle = d3
.select("g.nodes")
.selectAll("g")
- .data(this.forceData.nodes.nodes, function (d) {
+ .data(this.forceData.nodes.nodes, function(d) {
return d.uid();
});
@@ -539,23 +521,19 @@ class TopologyPage extends Component {
let enterCircle = this.circle
.enter()
.append("g")
- .attr("id", function (d) {
+ .attr("id", function(d) {
return (d.nodeType !== "normal" ? "router" : "client") + "-" + d.index;
});
let self = this;
appendCircle(enterCircle)
- .on("mouseover", function (d) {
+ .on("mouseover", function(d) {
// mouseover a circle
self.current_node = d;
- self.props.service.management.topology.delUpdatedAction(
- "connectionPopupHTML"
- );
+ self.props.service.management.topology.delUpdatedAction("connectionPopupHTML");
let e = d3.event;
self.popupCancelled = false;
- d.toolTip(self.props.service.management.topology).then(function (
- toolTip
- ) {
+ d.toolTip(self.props.service.management.topology).then(function(toolTip) {
self.showToolTip(toolTip, e);
});
if (d === self.mousedown_node) return;
@@ -574,14 +552,14 @@ class TopologyPage extends Component {
attrs: ["id", "nextHop"]
}
],
- function () {
+ function() {
self.mouseover_node = d; // save this node in case the topology changes so we can restore the highlights
self.nextHopHighlight(self.selected_node, d);
self.restart();
}
);
})
- .on("mouseout", function () {
+ .on("mouseout", function() {
// mouse out for a circle
self.current_node = null;
// unenlarge target node
@@ -596,7 +574,7 @@ class TopologyPage extends Component {
// mouse down for circle
this.backgroundMap.cancelZoom();
this.current_node = d;
- if (d3.event.button !== 0) {
+ if (d3.event && d3.event.button !== 0) {
// ignore all but left button
return;
}
@@ -604,7 +582,7 @@ class TopologyPage extends Component {
// mouse position relative to svg
this.initial_mouse_down_position = d3.mouse(this.svg.node());
})
- .on("mouseup", function (d) {
+ .on("mouseup", function(d) {
// mouse up for circle
self.backgroundMap.restartZoom();
if (!self.mousedown_node) return;
@@ -651,8 +629,12 @@ class TopologyPage extends Component {
})
.on("contextmenu", d => {
// circle
- d3.event.preventDefault();
- this.contextEventPosition = [d3.event.pageX, d3.event.pageY];
+ if (d3.event) {
+ d3.event.preventDefault();
+ this.contextEventPosition = [d3.event.pageX, d3.event.pageY];
+ } else {
+ this.contextEventPosition = [100, 100];
+ }
this.contextEventData = d;
this.setState({ showContextMenu: true });
return false;
@@ -687,7 +669,7 @@ class TopologyPage extends Component {
// add text to client circles if there are any that represent multiple clients
this.svg.selectAll(".subtext").remove();
let multiples = this.svg.selectAll(".multiple");
- multiples.each(function (d) {
+ multiples.each(function(d) {
let g = d3.select(this);
let r = Nodes.radius(d.nodeType);
g.append("svg:text")
@@ -719,7 +701,7 @@ class TopologyPage extends Component {
});
// draw lines from node centers
- this.path.selectAll("path").attr("d", function (d) {
+ this.path.selectAll("path").attr("d", function(d) {
return `M${d.source.x},${d.source.y}L${d.target.x},${d.target.y}`;
});
};
@@ -739,28 +721,18 @@ class TopologyPage extends Component {
let link = this.forceData.links.linkFor(selected_node, connected_node);
if (link) {
link.highlighted = true;
- d3.select(`path[id='hitpath-${link.uid}']`).classed(
- "highlighted",
- true
- );
+ d3.select(`path[id='hitpath-${link.uid}']`).classed("highlighted", true);
}
// start at the router
selected_node = connected_node;
}
if (d.nodeType !== "_topo") {
- let connected_node = this.forceData.nodes.find(
- d.routerId,
- {},
- d.routerId
- );
+ let connected_node = this.forceData.nodes.find(d.routerId, {}, d.routerId);
// push the link between the target_node and its router
let link = this.forceData.links.linkFor(d, connected_node);
if (link) {
link.highlighted = true;
- d3.select(`path[id='hitpath-${link.uid}']`).classed(
- "highlighted",
- true
- );
+ d3.select(`path[id='hitpath-${link.uid}']`).classed("highlighted", true);
}
// end at the router
d = connected_node;
@@ -774,10 +746,7 @@ class TopologyPage extends Component {
selected_node,
(link, fnode, tnode) => {
link.highlighted = true;
- d3.select(`path[id='hitpath-${link.uid}']`).classed(
- "highlighted",
- true
- );
+ d3.select(`path[id='hitpath-${link.uid}']`).classed("highlighted", true);
fnode.highlighted = true;
tnode.highlighted = true;
}
@@ -1006,7 +975,8 @@ class TopologyPage extends Component {
zoomOutCallback: this.zoomOutCallback,
resetViewCallback: this.resetViewCallback,
fitToScreenHidden: true,
- legendCallback: this.handleLegendClick
+ legendCallback: this.handleLegendClick,
+ legendAriaLabel: "topology-legend"
});
return (
<TopologyView
@@ -1029,7 +999,11 @@ class TopologyPage extends Component {
className="qdrTopology"
>
<div className="diagram">
- <div aria-label="topology-diagram" ref={el => (this.topologyRef = el)} id="topology"></div>
+ <div
+ aria-label="topology-diagram"
+ ref={el => (this.topologyRef = el)}
+ id="topology"
+ ></div>
</div>
{this.state.showContextMenu && (
<ContextMenu
@@ -1061,8 +1035,8 @@ class TopologyPage extends Component {
handleCloseRouterInfo={this.handleCloseRouterInfo}
/>
) : (
- <div />
- )}
+ <div />
+ )}
{this.state.showClientInfo ? (
<ClientInfoComponent
d={this.d}
@@ -1070,8 +1044,8 @@ class TopologyPage extends Component {
handleCloseClientInfo={this.handleCloseClientInfo}
/>
) : (
- <div />
- )}
+ <div />
+ )}
</TopologyView>
);
}
diff --git a/console/react/src/topology/topologyViewer.test.js b/console/react/src/topology/topologyViewer.test.js
index 91a6b12..382b950 100644
--- a/console/react/src/topology/topologyViewer.test.js
+++ b/console/react/src/topology/topologyViewer.test.js
@@ -1,15 +1,21 @@
import React from "react";
-import { render } from '@testing-library/react';
-import TopologyViewer from "./topologyViewer";
+import { render, fireEvent, waitForElement } from "@testing-library/react";
import { mockService } from "../qdrService.mock";
+import TopologyViewer from "./topologyViewer";
+import * as world from "../../public/data/countries.json";
-it("renders the TopologyViewer component", () => {
+it("renders the TopologyViewer component", async () => {
+ jest.spyOn(window, "fetch").mockImplementationOnce(() => {
+ return Promise.resolve({
+ json: () => Promise.resolve(world)
+ });
+ });
const props = {
service: mockService({})
- }
- const { getByLabelText } = render(
+ };
+ const { getByLabelText, getByText, getByTestId } = render(
<TopologyViewer {...props} />
- )
+ );
// make sure it rendered the component
const pfTopologyView = getByLabelText("topology-viewer");
@@ -18,4 +24,37 @@ it("renders the TopologyViewer component", () => {
// make sure it created the svg
expect(getByLabelText("topology-svg")).toBeInTheDocument();
+
+ // the svg should have a router circle
+ await waitForElement(() => getByTestId("router-0"));
+
+ // "click" on the router
+ const router = getByTestId("router-0");
+ fireEvent.mouseDown(router);
+ fireEvent.mouseUp(router);
+
+ // the routerInfo modal appears
+ await waitForElement(() => getByLabelText("Close"));
+ // close the modal
+ fireEvent.click(getByLabelText("Close"));
+
+ // the svg should have a client circle
+ const client = getByTestId("client-2");
+ // "click" on the client
+ fireEvent.mouseDown(client);
+ fireEvent.mouseUp(client);
+
+ // the clientInfo modal appears
+ await waitForElement(() => getByLabelText("Close"));
+ // close the modal
+ fireEvent.click(getByLabelText("Close"));
+
+ const legendButton = getByText("topology-legend");
+ expect(legendButton).toBeInTheDocument();
+
+ fireEvent.click(legendButton);
+ fireEvent.click(getByLabelText("Close"));
+
+ fireEvent.contextMenu(client);
+ fireEvent.click(pfTopologyView);
});
diff --git a/console/react/test_data/fetchEntities.js b/console/react/test_data/fetchEntities.js
new file mode 100644
index 0000000..f3f0902
--- /dev/null
+++ b/console/react/test_data/fetchEntities.js
@@ -0,0 +1,3836 @@
+/*
+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.
+*/
+
+export default {
+ "amqp:/_topo/0/A/$management": {
+ "router.node": {
+ results: [
+ ["A", 0],
+ ["B", 1]
+ ],
+ attributeNames: ["id", "index"]
+ },
+ log: {
+ results: [
+ [
+ "HTTP",
+ null,
+ null,
+ null,
+ null,
+ "log/HTTP",
+ "log/HTTP",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_LS",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_LS",
+ "log/ROUTER_LS",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "DEFAULT",
+ "info+",
+ true,
+ false,
+ "stderr",
+ "log/DEFAULT",
+ "log/DEFAULT",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "PYTHON",
+ null,
+ null,
+ null,
+ null,
+ "log/PYTHON",
+ "log/PYTHON",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_MA",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_MA",
+ "log/ROUTER_MA",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "CONN_MGR",
+ null,
+ null,
+ null,
+ null,
+ "log/CONN_MGR",
+ "log/CONN_MGR",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_HELLO",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_HELLO",
+ "log/ROUTER_HELLO",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "SERVER",
+ null,
+ null,
+ null,
+ null,
+ "log/SERVER",
+ "log/SERVER",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "POLICY",
+ null,
+ null,
+ null,
+ null,
+ "log/POLICY",
+ "log/POLICY",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "CONTAINER",
+ null,
+ null,
+ null,
+ null,
+ "log/CONTAINER",
+ "log/CONTAINER",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "AGENT",
+ null,
+ null,
+ null,
+ null,
+ "log/AGENT",
+ "log/AGENT",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ERROR",
+ null,
+ null,
+ null,
+ null,
+ "log/ERROR",
+ "log/ERROR",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_CORE",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_CORE",
+ "log/ROUTER_CORE",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER",
+ "log/ROUTER",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "MESSAGE",
+ null,
+ null,
+ null,
+ null,
+ "log/MESSAGE",
+ "log/MESSAGE",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "AUTHSERVICE",
+ null,
+ null,
+ null,
+ null,
+ "log/AUTHSERVICE",
+ "log/AUTHSERVICE",
+ "org.apache.qpid.dispatch.log"
+ ]
+ ],
+ attributeNames: [
+ "module",
+ "enable",
+ "includeTimestamp",
+ "includeSource",
+ "outputFile",
+ "name",
+ "identity",
+ "type"
+ ]
+ },
+ logStats: {
+ results: [
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "DEFAULT",
+ "logStats/DEFAULT",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ERROR",
+ "logStats/ERROR",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "PYTHON",
+ "logStats/PYTHON",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "MESSAGE",
+ "logStats/MESSAGE",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "MAIN",
+ "logStats/MAIN",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 1874,
+ 1,
+ 0,
+ 0,
+ 0,
+ 0,
+ "AGENT",
+ "logStats/AGENT",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 2,
+ 0,
+ 0,
+ 0,
+ 0,
+ "POLICY",
+ "logStats/POLICY",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "HTTP",
+ "logStats/HTTP",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 191,
+ 0,
+ 8,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_LS",
+ "logStats/ROUTER_LS",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 1,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_MA",
+ "logStats/ROUTER_MA",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 3,
+ 0,
+ 0,
+ 0,
+ 0,
+ "CONN_MGR",
+ "logStats/CONN_MGR",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 5344,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_HELLO",
+ "logStats/ROUTER_HELLO",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 16,
+ 4,
+ 0,
+ 0,
+ 0,
+ "SERVER",
+ "logStats/SERVER",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "CONTAINER",
+ "logStats/CONTAINER",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_CORE",
+ "logStats/ROUTER_CORE",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 6,
+ 1,
+ 75,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER",
+ "logStats/ROUTER",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "AUTHSERVICE",
+ "logStats/AUTHSERVICE",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "DISPLAYNAME",
+ "logStats/DISPLAYNAME",
+ "org.apache.qpid.dispatch.logStats"
+ ]
+ ],
+ attributeNames: [
+ "traceCount",
+ "debugCount",
+ "infoCount",
+ "noticeCount",
+ "warningCount",
+ "errorCount",
+ "criticalCount",
+ "name",
+ "identity",
+ "type"
+ ]
+ },
+ router: {
+ attributeNames: [
+ "name",
+ "identity",
+ "id",
+ "type",
+ "mode",
+ "area",
+ "version",
+ "addrCount",
+ "linkCount",
+ "nodeCount",
+ "linkRouteCount",
+ "autoLinkCount",
+ "connectionCount",
+ "presettledDeliveries",
+ "droppedPresettledDeliveries",
+ "acceptedDeliveries",
+ "rejectedDeliveries",
+ "releasedDeliveries",
+ "modifiedDeliveries",
+ "deliveriesDelayed1Sec",
+ "deliveriesDelayed10Sec",
+ "deliveriesIngress",
+ "deliveriesEgress",
+ "deliveriesTransit",
+ "deliveriesIngressRouteContainer",
+ "deliveriesEgressRouteContainer",
+ "deliveriesRedirectedToFallback"
+ ],
+ results: [
+ [
+ "A",
+ "1",
+ "A",
+ "org.apache.qpid.dispatch.router",
+ "interior",
+ "0",
+ "1.9.0-SNAPSHOT",
+ 13,
+ 25,
+ 1,
+ 0,
+ 0,
+ 3,
+ 0,
+ 0,
+ 31493,
+ 0,
+ 0,
+ 0,
+ 90,
+ 26130,
+ 31743,
+ 5248,
+ 29007,
+ 0,
+ 0,
+ 0
+ ]
+ ]
+ },
+ connection: {
+ attributeNames: [
+ "name",
+ "identity",
+ "host",
+ "role",
+ "dir",
+ "container",
+ "sasl",
+ "isAuthenticated",
+ "user",
+ "isEncrypted",
+ "sslProto",
+ "sslCipher",
+ "properties",
+ "sslSsf",
+ "tenant",
+ "type",
+ "ssl",
+ "opened",
+ "active",
+ "adminStatus",
+ "operStatus"
+ ],
+ results: [
+ [
+ "connection/127.0.0.1:60244",
+ "1",
+ "127.0.0.1:60244",
+ "inter-router",
+ "in",
+ "B",
+ "ANONYMOUS",
+ true,
+ "anonymous",
+ false,
+ null,
+ null,
+ {
+ product: "qpid-dispatch-router",
+ version: "1.9.0-SNAPSHOT",
+ "qd.conn-id": 1
+ },
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ],
+ [
+ "connection/127.0.0.1:53474",
+ "2",
+ "127.0.0.1:53474",
+ "normal",
+ "in",
+ "87c75b00-3eae-4289-b2ef-7faae85682b3",
+ "ANONYMOUS",
+ true,
+ "anonymous",
+ false,
+ null,
+ null,
+ {},
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ],
+ [
+ "connection/::1",
+ "8",
+ "::1",
+ "normal",
+ "in",
+ "9fdbf671-8845-ac4c-9912-21cad048e1c2",
+ null,
+ false,
+ "anonymous",
+ false,
+ null,
+ null,
+ {
+ console_identifier: "Dispatch console"
+ },
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ]
+ ]
+ },
+ "router.address": {
+ attributeNames: [
+ "name",
+ "identity",
+ "type",
+ "key",
+ "distribution",
+ "inProcess",
+ "subscriberCount",
+ "remoteCount",
+ "containerCount",
+ "remoteHostRouters",
+ "deliveriesIngress",
+ "deliveriesEgress",
+ "deliveriesTransit",
+ "deliveriesToContainer",
+ "deliveriesFromContainer",
+ "deliveriesEgressRouteContainer",
+ "deliveriesIngressRouteContainer",
+ "transitOutstanding",
+ "trackedDeliveries",
+ "priority",
+ "deliveriesRedirectedToFallback"
+ ],
+ results: [
+ [
+ "Lqdhello",
+ "Lqdhello",
+ "org.apache.qpid.dispatch.router.address",
+ "Lqdhello",
+ "flood",
+ 1,
+ 1,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 2671,
+ 2673,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Lqdrouter",
+ "Lqdrouter",
+ "org.apache.qpid.dispatch.router.address",
+ "Lqdrouter",
+ "flood",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 4,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Lqdrouter.ma",
+ "Lqdrouter.ma",
+ "org.apache.qpid.dispatch.router.address",
+ "Lqdrouter.ma",
+ "multicast",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Tqdrouter",
+ "Tqdrouter",
+ "org.apache.qpid.dispatch.router.address",
+ "Tqdrouter",
+ "flood",
+ 1,
+ 0,
+ 1,
+ 0,
+ ["B"],
+ 0,
+ 0,
+ 91,
+ 90,
+ 92,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Tqdrouter.ma",
+ "Tqdrouter.ma",
+ "org.apache.qpid.dispatch.router.address",
+ "Tqdrouter.ma",
+ "multicast",
+ 1,
+ 0,
+ 1,
+ 0,
+ ["B"],
+ 0,
+ 0,
+ 0,
+ 1,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0$qd.edge_addr_tracking",
+ "M0$qd.edge_addr_tracking",
+ "org.apache.qpid.dispatch.router.address",
+ "M0$qd.edge_addr_tracking",
+ "balanced",
+ 0,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0$qd.addr_lookup",
+ "M0$qd.addr_lookup",
+ "org.apache.qpid.dispatch.router.address",
+ "M0$qd.addr_lookup",
+ "balanced",
+ 0,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0$management",
+ "M0$management",
+ "org.apache.qpid.dispatch.router.address",
+ "M0$management",
+ "closest",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 199,
+ 0,
+ 0,
+ 199,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "L$management",
+ "L$management",
+ "org.apache.qpid.dispatch.router.address",
+ "L$management",
+ "closest",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 2537,
+ 0,
+ 0,
+ 2537,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "L$_management_internal",
+ "L$_management_internal",
+ "org.apache.qpid.dispatch.router.address",
+ "L$_management_internal",
+ "closest",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 898,
+ 898,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "RB",
+ "RB",
+ "org.apache.qpid.dispatch.router.address",
+ "RB",
+ "closest",
+ 0,
+ 0,
+ 1,
+ 0,
+ ["B"],
+ 2517,
+ 0,
+ 2521,
+ 0,
+ 4,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0toB",
+ "M0toB",
+ "org.apache.qpid.dispatch.router.address",
+ "M0toB",
+ "balanced",
+ 0,
+ 0,
+ 1,
+ 0,
+ ["B"],
+ 26490,
+ 0,
+ 26490,
+ 0,
+ 0,
+ 0,
+ 0,
+ [
+ 250,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0
+ ],
+ 250,
+ -1,
+ 0
+ ],
+ [
+ "Ltemp.YcA7nMPUSTUXLvX",
+ "Ltemp.YcA7nMPUSTUXLvX",
+ "org.apache.qpid.dispatch.router.address",
+ "Ltemp.YcA7nMPUSTUXLvX",
+ "balanced",
+ 0,
+ 1,
+ 0,
+ 0,
+ [],
+ 0,
+ 11,
+ 0,
+ 0,
+ 8,
+ 0,
+ 0,
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0
+ ],
+ 0,
+ -1,
+ 0
+ ]
+ ]
+ },
+ "router.link": {
+ attributeNames: [
+ "name",
+ "identity",
+ "type",
+ "linkName",
+ "linkType",
+ "linkDir",
+ "owningAddr",
+ "capacity",
+ "peer",
+ "undeliveredCount",
+ "unsettledCount",
+ "deliveryCount",
+ "connectionId",
+ "adminStatus",
+ "operStatus",
+ "presettledCount",
+ "droppedPresettledCount",
+ "acceptedCount",
+ "rejectedCount",
+ "releasedCount",
+ "modifiedCount",
+ "deliveriesDelayed1Sec",
+ "deliveriesDelayed10Sec",
+ "ingressHistogram",
+ "priority",
+ "settleRate"
+ ],
+ results: [
+ [
+ "qdlink.HlE3UASSFLV752W",
+ "1",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.HlE3UASSFLV752W",
+ "router-control",
+ "out",
+ "Lqdhello",
+ 250,
+ null,
+ 0,
+ 0,
+ 25137,
+ "1",
+ "enabled",
+ "up",
+ 25137,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.C6KVq3vkFQ32OOk",
+ "2",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.C6KVq3vkFQ32OOk",
+ "router-control",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 25137,
+ "1",
+ "enabled",
+ "up",
+ 25137,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 1
+ ],
+ [
+ "qdlink.ptWU55qBgJu6vEP",
+ "3",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.ptWU55qBgJu6vEP",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.mMWvv2Qkl7axiGL",
+ "4",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.mMWvv2Qkl7axiGL",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.IWWZ6XNE_Mm+i7s",
+ "5",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.IWWZ6XNE_Mm+i7s",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 1,
+ 0
+ ],
+ [
+ "qdlink.pBCUdQxxhBB2CC8",
+ "6",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.pBCUdQxxhBB2CC8",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.cH8isYfcxJBuCU6",
+ "7",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.cH8isYfcxJBuCU6",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 2,
+ 0
+ ],
+ [
+ "qdlink.DceyJ0JJVGInisj",
+ "8",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.DceyJ0JJVGInisj",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.bFL8XkygAKoMIIK",
+ "9",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.bFL8XkygAKoMIIK",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 3,
+ 0
+ ],
+ [
+ "qdlink.RtgqZrOrSuwVZTL",
+ "10",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.RtgqZrOrSuwVZTL",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.E0rBQ_++yb7FEMC",
+ "11",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.E0rBQ_++yb7FEMC",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 250,
+ 258141,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 90,
+ 242220,
+ null,
+ 4,
+ 0
+ ],
+ [
+ "qdlink.8ql1AqDuJ9Mwopf",
+ "12",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.8ql1AqDuJ9Mwopf",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 15559,
+ "1",
+ "enabled",
+ "up",
+ 15559,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 1
+ ],
+ [
+ "qdlink.HFFTij9L_ZjQzLJ",
+ "13",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.HFFTij9L_ZjQzLJ",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 5,
+ 0
+ ],
+ [
+ "qdlink.rSfNDFepjUfRdUd",
+ "14",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.rSfNDFepjUfRdUd",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.co1Erzq3OfR3P2+",
+ "15",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.co1Erzq3OfR3P2+",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 6,
+ 0
+ ],
+ [
+ "qdlink.YErp_Dqo_ehs8tB",
+ "16",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.YErp_Dqo_ehs8tB",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.oGY6hVxub6QU4Vj",
+ "17",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.oGY6hVxub6QU4Vj",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 7,
+ 0
+ ],
+ [
+ "qdlink.k91TFsV3LokqZ4C",
+ "18",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.k91TFsV3LokqZ4C",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.o+uHBeFqSCVE8A+",
+ "19",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.o+uHBeFqSCVE8A+",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 8,
+ 0
+ ],
+ [
+ "qdlink.ZPNRS3549cd0HoR",
+ "20",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.ZPNRS3549cd0HoR",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.5hC8iIL38YfWgSs",
+ "21",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.5hC8iIL38YfWgSs",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 9,
+ 0
+ ],
+ [
+ "qdlink.kdS8+8+uqrdxJ7I",
+ "22",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.kdS8+8+uqrdxJ7I",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "87c75b00-3eae-4289-b2ef-7faae85682b3-toB",
+ "23",
+ "org.apache.qpid.dispatch.router.link",
+ "87c75b00-3eae-4289-b2ef-7faae85682b3-toB",
+ "endpoint",
+ "in",
+ "M0toB",
+ 250,
+ null,
+ 0,
+ 250,
+ 242580,
+ "2",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 242330,
+ 0,
+ 0,
+ 0,
+ 90,
+ 242220,
+ null,
+ 0,
+ 8
+ ],
+ [
+ "7f98817b-9849-474c-ae01-95abb185515f",
+ "94",
+ "org.apache.qpid.dispatch.router.link",
+ "7f98817b-9849-474c-ae01-95abb185515f",
+ "endpoint",
+ "out",
+ "Ltemp.kNLcXicad9jl7qj",
+ 250,
+ null,
+ 0,
+ 0,
+ 50,
+ "38",
+ "enabled",
+ "up",
+ 50,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ [
+ 14,
+ 9,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0
+ ],
+ 0,
+ 3
+ ],
+ [
+ "5e3e601e-1555-1446-864b-b8ab047e4da3",
+ "95",
+ "org.apache.qpid.dispatch.router.link",
+ "5e3e601e-1555-1446-864b-b8ab047e4da3",
+ "endpoint",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 53,
+ "38",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 53,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 4
+ ]
+ ]
+ }
+ },
+ "amqp:/_topo/0/B/$management": {
+ "router.node": {
+ results: [
+ ["B", 0],
+ ["A", 1]
+ ],
+ attributeNames: ["id", "index"]
+ },
+ connection: {
+ attributeNames: [
+ "name",
+ "identity",
+ "host",
+ "role",
+ "dir",
+ "container",
+ "sasl",
+ "isAuthenticated",
+ "user",
+ "isEncrypted",
+ "sslProto",
+ "sslCipher",
+ "properties",
+ "sslSsf",
+ "tenant",
+ "type",
+ "ssl",
+ "opened",
+ "active",
+ "adminStatus",
+ "operStatus"
+ ],
+ results: [
+ [
+ "connection/0.0.0.0:2000",
+ "1",
+ "0.0.0.0:2000",
+ "inter-router",
+ "out",
+ "A",
+ "ANONYMOUS",
+ true,
+ null,
+ false,
+ null,
+ null,
+ {
+ product: "qpid-dispatch-router",
+ version: "1.9.0-SNAPSHOT",
+ "qd.conn-id": 1
+ },
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ],
+ [
+ "connection/127.0.0.1:34780",
+ "2",
+ "127.0.0.1:34780",
+ "normal",
+ "in",
+ "af560918-3c35-4bf4-a9da-eef5a11ff7ec",
+ "ANONYMOUS",
+ true,
+ "anonymous",
+ false,
+ null,
+ null,
+ {},
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ]
+ ]
+ },
+ log: {
+ results: [
+ [
+ "HTTP",
+ null,
+ null,
+ null,
+ null,
+ "log/HTTP",
+ "log/HTTP",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_LS",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_LS",
+ "log/ROUTER_LS",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "DEFAULT",
+ "info+",
+ true,
+ false,
+ "stderr",
+ "log/DEFAULT",
+ "log/DEFAULT",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "PYTHON",
+ null,
+ null,
+ null,
+ null,
+ "log/PYTHON",
+ "log/PYTHON",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_MA",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_MA",
+ "log/ROUTER_MA",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "CONN_MGR",
+ null,
+ null,
+ null,
+ null,
+ "log/CONN_MGR",
+ "log/CONN_MGR",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_HELLO",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_HELLO",
+ "log/ROUTER_HELLO",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "SERVER",
+ null,
+ null,
+ null,
+ null,
+ "log/SERVER",
+ "log/SERVER",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "POLICY",
+ null,
+ null,
+ null,
+ null,
+ "log/POLICY",
+ "log/POLICY",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "CONTAINER",
+ null,
+ null,
+ null,
+ null,
+ "log/CONTAINER",
+ "log/CONTAINER",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "AGENT",
+ null,
+ null,
+ null,
+ null,
+ "log/AGENT",
+ "log/AGENT",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ERROR",
+ null,
+ null,
+ null,
+ null,
+ "log/ERROR",
+ "log/ERROR",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER_CORE",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER_CORE",
+ "log/ROUTER_CORE",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "ROUTER",
+ null,
+ null,
+ null,
+ null,
+ "log/ROUTER",
+ "log/ROUTER",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "MESSAGE",
+ null,
+ null,
+ null,
+ null,
+ "log/MESSAGE",
+ "log/MESSAGE",
+ "org.apache.qpid.dispatch.log"
+ ],
+ [
+ "AUTHSERVICE",
+ null,
+ null,
+ null,
+ null,
+ "log/AUTHSERVICE",
+ "log/AUTHSERVICE",
+ "org.apache.qpid.dispatch.log"
+ ]
+ ],
+ attributeNames: [
+ "module",
+ "enable",
+ "includeTimestamp",
+ "includeSource",
+ "outputFile",
+ "name",
+ "identity",
+ "type"
+ ]
+ },
+ logStats: {
+ results: [
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "DEFAULT",
+ "logStats/DEFAULT",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ERROR",
+ "logStats/ERROR",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "PYTHON",
+ "logStats/PYTHON",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "MESSAGE",
+ "logStats/MESSAGE",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "MAIN",
+ "logStats/MAIN",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 1470,
+ 1,
+ 0,
+ 0,
+ 0,
+ 0,
+ "AGENT",
+ "logStats/AGENT",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 2,
+ 0,
+ 0,
+ 0,
+ 0,
+ "POLICY",
+ "logStats/POLICY",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "HTTP",
+ "logStats/HTTP",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 191,
+ 0,
+ 4,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_LS",
+ "logStats/ROUTER_LS",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 1,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_MA",
+ "logStats/ROUTER_MA",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 2,
+ 0,
+ 0,
+ 0,
+ 0,
+ "CONN_MGR",
+ "logStats/CONN_MGR",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 5343,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_HELLO",
+ "logStats/ROUTER_HELLO",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 3,
+ 2,
+ 0,
+ 0,
+ 0,
+ "SERVER",
+ "logStats/SERVER",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "CONTAINER",
+ "logStats/CONTAINER",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER_CORE",
+ "logStats/ROUTER_CORE",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 6,
+ 0,
+ 20,
+ 0,
+ 0,
+ 0,
+ 0,
+ "ROUTER",
+ "logStats/ROUTER",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "AUTHSERVICE",
+ "logStats/AUTHSERVICE",
+ "org.apache.qpid.dispatch.logStats"
+ ],
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ "DISPLAYNAME",
+ "logStats/DISPLAYNAME",
+ "org.apache.qpid.dispatch.logStats"
+ ]
+ ],
+ attributeNames: [
+ "traceCount",
+ "debugCount",
+ "infoCount",
+ "noticeCount",
+ "warningCount",
+ "errorCount",
+ "criticalCount",
+ "name",
+ "identity",
+ "type"
+ ]
+ },
+ router: {
+ attributeNames: [
+ "name",
+ "identity",
+ "id",
+ "type",
+ "mode",
+ "area",
+ "version",
+ "addrCount",
+ "linkCount",
+ "nodeCount",
+ "linkRouteCount",
+ "autoLinkCount",
+ "connectionCount",
+ "presettledDeliveries",
+ "droppedPresettledDeliveries",
+ "acceptedDeliveries",
+ "rejectedDeliveries",
+ "releasedDeliveries",
+ "modifiedDeliveries",
+ "deliveriesDelayed1Sec",
+ "deliveriesDelayed10Sec",
+ "deliveriesIngress",
+ "deliveriesEgress",
+ "deliveriesTransit",
+ "deliveriesIngressRouteContainer",
+ "deliveriesEgressRouteContainer",
+ "deliveriesRedirectedToFallback"
+ ],
+ results: [
+ [
+ "B",
+ "1",
+ "B",
+ "org.apache.qpid.dispatch.router",
+ "interior",
+ "0",
+ "1.9.0-SNAPSHOT",
+ 12,
+ 23,
+ 1,
+ 0,
+ 0,
+ 2,
+ 0,
+ 0,
+ 28761,
+ 0,
+ 0,
+ 0,
+ 90,
+ 26130,
+ 0,
+ 26490,
+ 2519,
+ 0,
+ 0,
+ 0
+ ]
+ ]
+ },
+ "router.address": {
+ attributeNames: [
+ "name",
+ "identity",
+ "type",
+ "key",
+ "distribution",
+ "inProcess",
+ "subscriberCount",
+ "remoteCount",
+ "containerCount",
+ "remoteHostRouters",
+ "deliveriesIngress",
+ "deliveriesEgress",
+ "deliveriesTransit",
+ "deliveriesToContainer",
+ "deliveriesFromContainer",
+ "deliveriesEgressRouteContainer",
+ "deliveriesIngressRouteContainer",
+ "transitOutstanding",
+ "trackedDeliveries",
+ "priority",
+ "deliveriesRedirectedToFallback"
+ ],
+ results: [
+ [
+ "Lqdhello",
+ "Lqdhello",
+ "org.apache.qpid.dispatch.router.address",
+ "Lqdhello",
+ "flood",
+ 1,
+ 1,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 2672,
+ 2671,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Lqdrouter",
+ "Lqdrouter",
+ "org.apache.qpid.dispatch.router.address",
+ "Lqdrouter",
+ "flood",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 4,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Lqdrouter.ma",
+ "Lqdrouter.ma",
+ "org.apache.qpid.dispatch.router.address",
+ "Lqdrouter.ma",
+ "multicast",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Tqdrouter",
+ "Tqdrouter",
+ "org.apache.qpid.dispatch.router.address",
+ "Tqdrouter",
+ "flood",
+ 1,
+ 0,
+ 1,
+ 0,
+ ["A"],
+ 0,
+ 0,
+ 90,
+ 91,
+ 91,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "Tqdrouter.ma",
+ "Tqdrouter.ma",
+ "org.apache.qpid.dispatch.router.address",
+ "Tqdrouter.ma",
+ "multicast",
+ 1,
+ 0,
+ 1,
+ 0,
+ ["A"],
+ 0,
+ 0,
+ 1,
+ 0,
+ 1,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0$qd.edge_addr_tracking",
+ "M0$qd.edge_addr_tracking",
+ "org.apache.qpid.dispatch.router.address",
+ "M0$qd.edge_addr_tracking",
+ "balanced",
+ 0,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0$qd.addr_lookup",
+ "M0$qd.addr_lookup",
+ "org.apache.qpid.dispatch.router.address",
+ "M0$qd.addr_lookup",
+ "balanced",
+ 0,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0$management",
+ "M0$management",
+ "org.apache.qpid.dispatch.router.address",
+ "M0$management",
+ "closest",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "L$management",
+ "L$management",
+ "org.apache.qpid.dispatch.router.address",
+ "L$management",
+ "closest",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 2523,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "L$_management_internal",
+ "L$_management_internal",
+ "org.apache.qpid.dispatch.router.address",
+ "L$_management_internal",
+ "closest",
+ 1,
+ 0,
+ 0,
+ 0,
+ [],
+ 0,
+ 0,
+ 0,
+ 696,
+ 696,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "RA",
+ "RA",
+ "org.apache.qpid.dispatch.router.address",
+ "RA",
+ "closest",
+ 0,
+ 0,
+ 1,
+ 0,
+ ["A"],
+ 0,
+ 0,
+ 2525,
+ 0,
+ 2525,
+ 0,
+ 0,
+ null,
+ 0,
+ -1,
+ 0
+ ],
+ [
+ "M0toB",
+ "M0toB",
+ "org.apache.qpid.dispatch.router.address",
+ "M0toB",
+ "balanced",
+ 0,
+ 1,
+ 0,
+ 0,
+ [],
+ 0,
+ 26490,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ [
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0
+ ],
+ 0,
+ -1,
+ 0
+ ]
+ ]
+ },
+ "router.link": {
+ attributeNames: [
+ "name",
+ "identity",
+ "type",
+ "linkName",
+ "linkType",
+ "linkDir",
+ "owningAddr",
+ "capacity",
+ "peer",
+ "undeliveredCount",
+ "unsettledCount",
+ "deliveryCount",
+ "connectionId",
+ "adminStatus",
+ "operStatus",
+ "presettledCount",
+ "droppedPresettledCount",
+ "acceptedCount",
+ "rejectedCount",
+ "releasedCount",
+ "modifiedCount",
+ "deliveriesDelayed1Sec",
+ "deliveriesDelayed10Sec",
+ "ingressHistogram",
+ "priority",
+ "settleRate"
+ ],
+ results: [
+ [
+ "qdlink.HlE3UASSFLV752W",
+ "1",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.HlE3UASSFLV752W",
+ "router-control",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 25137,
+ "1",
+ "enabled",
+ "up",
+ 25137,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.C6KVq3vkFQ32OOk",
+ "2",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.C6KVq3vkFQ32OOk",
+ "router-control",
+ "out",
+ "Lqdhello",
+ 250,
+ null,
+ 0,
+ 0,
+ 25137,
+ "1",
+ "enabled",
+ "up",
+ 25137,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 1
+ ],
+ [
+ "qdlink.ptWU55qBgJu6vEP",
+ "3",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.ptWU55qBgJu6vEP",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.mMWvv2Qkl7axiGL",
+ "4",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.mMWvv2Qkl7axiGL",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.IWWZ6XNE_Mm+i7s",
+ "5",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.IWWZ6XNE_Mm+i7s",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.pBCUdQxxhBB2CC8",
+ "6",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.pBCUdQxxhBB2CC8",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 1,
+ 0
+ ],
+ [
+ "qdlink.cH8isYfcxJBuCU6",
+ "7",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.cH8isYfcxJBuCU6",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.DceyJ0JJVGInisj",
+ "8",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.DceyJ0JJVGInisj",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 2,
+ 0
+ ],
+ [
+ "qdlink.bFL8XkygAKoMIIK",
+ "9",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.bFL8XkygAKoMIIK",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.RtgqZrOrSuwVZTL",
+ "10",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.RtgqZrOrSuwVZTL",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 3,
+ 0
+ ],
+ [
+ "qdlink.E0rBQ_++yb7FEMC",
+ "11",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.E0rBQ_++yb7FEMC",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 250,
+ 258141,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 257891,
+ 0,
+ 0,
+ 0,
+ 90,
+ 242220,
+ null,
+ 0,
+ 10
+ ],
+ [
+ "qdlink.8ql1AqDuJ9Mwopf",
+ "12",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.8ql1AqDuJ9Mwopf",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 15560,
+ "1",
+ "enabled",
+ "up",
+ 15560,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 4,
+ 1
+ ],
+ [
+ "qdlink.HFFTij9L_ZjQzLJ",
+ "13",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.HFFTij9L_ZjQzLJ",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.rSfNDFepjUfRdUd",
+ "14",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.rSfNDFepjUfRdUd",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 5,
+ 0
+ ],
+ [
+ "qdlink.co1Erzq3OfR3P2+",
+ "15",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.co1Erzq3OfR3P2+",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.YErp_Dqo_ehs8tB",
+ "16",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.YErp_Dqo_ehs8tB",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 6,
+ 0
+ ],
+ [
+ "qdlink.oGY6hVxub6QU4Vj",
+ "17",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.oGY6hVxub6QU4Vj",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.k91TFsV3LokqZ4C",
+ "18",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.k91TFsV3LokqZ4C",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 7,
+ 0
+ ],
+ [
+ "qdlink.o+uHBeFqSCVE8A+",
+ "19",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.o+uHBeFqSCVE8A+",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.ZPNRS3549cd0HoR",
+ "20",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.ZPNRS3549cd0HoR",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 8,
+ 0
+ ],
+ [
+ "qdlink.5hC8iIL38YfWgSs",
+ "21",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.5hC8iIL38YfWgSs",
+ "inter-router",
+ "in",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 0,
+ 0
+ ],
+ [
+ "qdlink.kdS8+8+uqrdxJ7I",
+ "22",
+ "org.apache.qpid.dispatch.router.link",
+ "qdlink.kdS8+8+uqrdxJ7I",
+ "inter-router",
+ "out",
+ null,
+ 250,
+ null,
+ 0,
+ 0,
+ 0,
+ "1",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ null,
+ 9,
+ 0
+ ],
+ [
+ "af560918-3c35-4bf4-a9da-eef5a11ff7ec-toB",
+ "23",
+ "org.apache.qpid.dispatch.router.link",
+ "af560918-3c35-4bf4-a9da-eef5a11ff7ec-toB",
+ "endpoint",
+ "out",
+ "M0toB",
+ 250,
+ null,
+ 250,
+ 0,
+ 242330,
+ "2",
+ "enabled",
+ "up",
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 90,
+ 242220,
+ [
+ 0,
+ 242330,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0,
+ 0
+ ],
+ 0,
+ 0
+ ]
+ ]
+ }
+ }
+};
diff --git a/console/react/test_data/nodeInfo.js b/console/react/test_data/nodeInfo.js
new file mode 100644
index 0000000..2583f7f
--- /dev/null
+++ b/console/react/test_data/nodeInfo.js
@@ -0,0 +1,206 @@
+/*
+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.
+*/
+
+export default {
+ "amqp:/_topo/0/A/$management": {
+ connection: {
+ attributeNames: [
+ "name",
+ "identity",
+ "host",
+ "role",
+ "dir",
+ "container",
+ "sasl",
+ "isAuthenticated",
+ "user",
+ "isEncrypted",
+ "sslProto",
+ "sslCipher",
+ "properties",
+ "sslSsf",
+ "tenant",
+ "type",
+ "ssl",
+ "opened",
+ "active",
+ "adminStatus",
+ "operStatus"
+ ],
+ results: [
+ [
+ "connection/127.0.0.1:60244",
+ "1",
+ "127.0.0.1:60244",
+ "inter-router",
+ "in",
+ "B",
+ "ANONYMOUS",
+ true,
+ "anonymous",
+ false,
+ null,
+ null,
+ {
+ product: "qpid-dispatch-router",
+ version: "1.9.0-SNAPSHOT",
+ "qd.conn-id": 1
+ },
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ],
+ [
+ "connection/127.0.0.1:53474",
+ "2",
+ "127.0.0.1:53474",
+ "normal",
+ "in",
+ "87c75b00-3eae-4289-b2ef-7faae85682b3",
+ "ANONYMOUS",
+ true,
+ "anonymous",
+ false,
+ null,
+ null,
+ {},
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ],
+ [
+ "connection/::1",
+ "8",
+ "::1",
+ "normal",
+ "in",
+ "9fdbf671-8845-ac4c-9912-21cad048e1c2",
+ null,
+ false,
+ "anonymous",
+ false,
+ null,
+ null,
+ {
+ console_identifier: "Dispatch console"
+ },
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ]
+ ],
+ timestamp: "2019-11-16T14:25:47.289Z"
+ }
+ },
+ "amqp:/_topo/0/B/$management": {
+ connection: {
+ attributeNames: [
+ "name",
+ "identity",
+ "host",
+ "role",
+ "dir",
+ "container",
+ "sasl",
+ "isAuthenticated",
+ "user",
+ "isEncrypted",
+ "sslProto",
+ "sslCipher",
+ "properties",
+ "sslSsf",
+ "tenant",
+ "type",
+ "ssl",
+ "opened",
+ "active",
+ "adminStatus",
+ "operStatus"
+ ],
+ results: [
+ [
+ "connection/0.0.0.0:2000",
+ "1",
+ "0.0.0.0:2000",
+ "inter-router",
+ "out",
+ "A",
+ "ANONYMOUS",
+ true,
+ null,
+ false,
+ null,
+ null,
+ {
+ product: "qpid-dispatch-router",
+ version: "1.9.0-SNAPSHOT",
+ "qd.conn-id": 1
+ },
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ],
+ [
+ "connection/127.0.0.1:34780",
+ "2",
+ "127.0.0.1:34780",
+ "normal",
+ "in",
+ "af560918-3c35-4bf4-a9da-eef5a11ff7ec",
+ "ANONYMOUS",
+ true,
+ "anonymous",
+ false,
+ null,
+ null,
+ {},
+ 0,
+ null,
+ "org.apache.qpid.dispatch.connection",
+ false,
+ true,
+ true,
+ "enabled",
+ "up"
+ ]
+ ],
+ timestamp: "2019-11-16T14:25:47.290Z"
+ }
+ }
+};
diff --git a/console/react/test_data/schema.js b/console/react/test_data/schema.js
new file mode 100644
index 0000000..df33351
--- /dev/null
+++ b/console/react/test_data/schema.js
@@ -0,0 +1,1922 @@
+/*
+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.
+*/
+
+export default {
+ prefix: "org.apache.qpid.dispatch",
+ entityTypes: {
+ dummy: {
+ operations: ["CREATE", "READ", "UPDATE", "DELETE", "CALLME"],
+ attributes: {
+ num1: {
+ type: "integer"
+ },
+ num2: {
+ type: "integer"
+ },
+ arg1: {
+ type: "string"
+ },
+ arg2: {
+ type: "string"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.dummy",
+ description: "Dummy entity for test purposes."
+ },
+ binding: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ matchedCount: {
+ type: "integer",
+ description: "Total number of deliveries that matched this binding."
+ },
+ bindingKey: {
+ type: "string",
+ description:
+ "Pattern to compare against incoming message's subject. The key is a string of zero or more tokens and wildcards. The format depends on the matchMethod configured for the exchange. For AMQP each token is delimited by the '.' character and wild-card tokens '*' matches a single token and '#' matches zero or more tokens. For MQTT each token is delimited by the '/' character and wildcard tokens '+' matches a single token and '#' matches zero or more tokens at the end of the topi [...]
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ nextHopAddress: {
+ required: true,
+ type: "string",
+ description:
+ "The address to forward the message to when the message's topic string matches the binding key pattern. This address is used by message consumers as the source of incoming messages."
+ },
+ exchangeName: {
+ required: true,
+ type: "string",
+ description: "The name of the exchange to bind."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ nextHopPhase: {
+ type: "integer",
+ description: "The address phase used when forwarding messages that match this binding."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.config.binding",
+ description:
+ "[EXPERIMENTAL] Defines a keyed next hop binding for a topic exchange. The subject field of the messages arriving at the exchange is compared against the binding's key value using the exchange's matchMethod. If the subject matches the key the message is forwarded to the nextHopAddress. The nextHopAddress overrides the message's original destination."
+ },
+ entity: {
+ attributes: {
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.entity",
+ description: "Base entity type for all entities."
+ },
+ "router.connection.linkRoute": {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ pattern: {
+ required: true,
+ type: "string",
+ description:
+ "A wildcarded pattern for address matching. Incoming addresses are matched against this pattern. Matching addresses use the configured settings. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match ha [...]
+ },
+ direction: {
+ required: true,
+ type: ["in", "out"],
+ description:
+ "The permitted direction of links: 'in' means client senders; 'out' means client receivers"
+ },
+ containerId: {
+ type: "string",
+ description: "Name of the container which has instantiated this linkRoute."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.connection.linkRoute",
+ description:
+ "[EXPERIMENTAL] A linkRoute that is scoped to the connection that created it. Connection linkRoutes only exist within the context of a connection and when the connection is closed, they vanish. This differs from configured linkRoutes (router.config.linkRoute) which remain configured should their associated connection restart. Connection linkRoutes may be used by a client to create link-routed message flows that are automatically removed when the client disconnects. Note well tha [...]
+ },
+ sslProfile: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ certFile: {
+ type: "path",
+ description:
+ "The absolute path to the file containing the PEM-formatted public certificate to be used on the local end of any connections using this profile."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ uidNameMappingFile: {
+ type: "string",
+ description:
+ "The absolute path to the file containing the unique id to display name mapping"
+ },
+ ciphers: {
+ type: "string",
+ description:
+ "Specifies the enabled ciphers so the SSL Ciphers can be hardened. In other words, use this field to disable weak ciphers. The ciphers are specified in the format understood by the OpenSSL library. For example, ciphers can be set to ALL:!aNULL:!EXPORT56:RC4+RSA:+HIGH:+MEDIUM:+LOW:+SSLv2:+EXP; -- The full list of allowed ciphers can be viewed using the openssl ciphers command"
+ },
+ uidFormat: {
+ type: "string",
+ description:
+ "A list of x509 client certificate fields that will be used to build a string that will uniquely identify the client certificate owner. For e.g. a value of 'cou' indicates that the uid will consist of c - common name concatenated with o - organization-company name concatenated with u - organization unit; or a value of 'o2' indicates that the uid will consist of o (organization name) concatenated with 2 (the sha256 fingerprint of the entire certificate) . Allowed values can be [...]
+ },
+ privateKeyFile: {
+ type: "path",
+ description:
+ "The absolute path to the file containing the PEM-formatted private key for the above certificate."
+ },
+ protocols: {
+ type: "string",
+ description:
+ "The TLS protocols that this sslProfile can use. You can specify a list of one or more of TLSv1, TLSv1.1, or TLSv1.2. To specify multiple protocols, separate the protocols with a space. For example, to permit the sslProfile to use TLS v1.1 and TLS v1.2 only, you would set the value to TLSv1.1 TLSv1.2. If you do not specify a value, the sslProfile uses the TLS protocol specified by the system-wide configuration."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ passwordFile: {
+ type: "path",
+ description:
+ "If the above private key is password protected, this is the absolute path to a file containing the password that unlocks the certificate key. This file should be permission protected to limit access"
+ },
+ caCertFile: {
+ type: "path",
+ description:
+ "The absolute path to the database that contains the public certificates of trusted certificate authorities (CA)."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.sslProfile",
+ description: "Attributes for setting TLS/SSL configuration for connections."
+ },
+ linkRoute: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ direction: {
+ required: true,
+ type: ["in", "out"],
+ description:
+ "The permitted direction of links: 'in' means client senders; 'out' means client receivers"
+ },
+ addExternalPrefix: {
+ type: "string",
+ description:
+ "add the specified prefix to the address of the remote terminus on the route container link"
+ },
+ operStatus: {
+ type: ["inactive", "active"],
+ description:
+ "The operational status of this linkRoute: inactive - The remote container is not connected; active - the remote container is connected and ready to accept link routed attachments."
+ },
+ pattern: {
+ type: "string",
+ description:
+ "A wildcarded pattern for address matching. Link addresses are matched against this pattern. Matching addresses use the configured settings. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match has th [...]
+ },
+ connection: {
+ type: "string",
+ description:
+ "The name from a connector or listener. Only one of containerId or connection should be specified for a linkRoute. Specifying both will result in the linkRoute not being created."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ prefix: {
+ type: "string",
+ description:
+ "The address prefix for the configured settings. Cannot be used with the pattern attribute."
+ },
+ distribution: {
+ default: "linkBalanced",
+ type: ["linkBalanced"],
+ description: "Treatment of traffic associated with the address"
+ },
+ delExternalPrefix: {
+ type: "string",
+ description:
+ "remove the specified prefix to the address of the remote terminus on the route container link"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ containerId: {
+ type: "string",
+ description:
+ "ContainerID for the target container. Only one of containerId or connection should be specified for a linkRoute. Specifying both will result in the linkRoute not being created."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.config.linkRoute",
+ description:
+ "Entity type for link-route configuration. This is used to identify remote containers that shall be destinations for routed link-attaches. The link-routing configuration applies to an addressing space defined by a prefix or a pattern."
+ },
+ allocator: {
+ operations: ["READ"],
+ attributes: {
+ heldByThreads: {
+ graph: true,
+ type: "integer"
+ },
+ typeSize: {
+ type: "integer"
+ },
+ transferBatchSize: {
+ type: "integer"
+ },
+ globalFreeListMax: {
+ graph: true,
+ type: "integer"
+ },
+ batchesRebalancedToGlobal: {
+ graph: true,
+ type: "integer"
+ },
+ typeName: {
+ type: "string"
+ },
+ batchesRebalancedToThreads: {
+ graph: true,
+ type: "integer"
+ },
+ totalFreeToHeap: {
+ graph: true,
+ type: "integer"
+ },
+ totalAllocFromHeap: {
+ graph: true,
+ type: "integer"
+ },
+ localFreeListMax: {
+ graph: true,
+ type: "integer"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.allocator",
+ description: "Memory allocation pool."
+ },
+ management: {
+ operations: [
+ "GET-SCHEMA",
+ "GET-JSON-SCHEMA",
+ "GET-LOG",
+ "PROFILE",
+ "QUERY",
+ "GET-TYPES",
+ "GET-ANNOTATIONS",
+ "GET-OPERATIONS",
+ "GET-ATTRIBUTES",
+ "GET-MGMT-NODES",
+ "READ"
+ ],
+ attributes: {
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ singleton: true,
+ fullyQualifiedType: "org.apache.qpid.dispatch.management",
+ description: "Qpid dispatch router extensions to the standard org.amqp.management interface."
+ },
+ log: {
+ operations: ["UPDATE", "READ"],
+ attributes: {
+ outputFile: {
+ type: "string",
+ description:
+ "Where to send log messages. Can be 'stderr', 'stdout', 'syslog' or a file name."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ module: {
+ required: true,
+ type: [
+ "ROUTER",
+ "ROUTER_CORE",
+ "ROUTER_HELLO",
+ "ROUTER_LS",
+ "ROUTER_MA",
+ "MESSAGE",
+ "SERVER",
+ "AGENT",
+ "AUTHSERVICE",
+ "CONTAINER",
+ "ERROR",
+ "POLICY",
+ "HTTP",
+ "CONN_MGR",
+ "PYTHON",
+ "DEFAULT"
+ ],
+ description:
+ "Module to configure. The special module 'DEFAULT' specifies defaults for all modules."
+ },
+ enable: {
+ type: "string",
+ description:
+ "Levels are: trace, debug, info, notice, warning, error, critical. The enable string is a comma-separated list of levels. A level may have a trailing '\\+' to enable that level and above. For example 'trace,debug,warning+' means enable trace, debug, warning, error and critical. The value 'none' means disable logging for the module."
+ },
+ includeSource: {
+ type: "boolean",
+ description: "Include source file and line number in log messages."
+ },
+ includeTimestamp: {
+ type: "boolean",
+ description: "Include timestamp in log messages."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.log",
+ description:
+ "Configure logging for a particular module. You can use the `UPDATE` operation to change log settings while the router is running."
+ },
+ vhostUserGroupSettings: {
+ operations: ["READ"],
+ attributes: {
+ allowFallbackLinks: {
+ default: true,
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to claim 'qd.fallback' capability for attached links. This allows endpoints to act as fallback destinations for addresses that have fallback capability enabled."
+ },
+ allowAnonymousSender: {
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to create sending links if the sender does not provide a target address. By prohibiting anonymous senders, the router only needs to verify once, when the link is created, that the sender is permitted to send messages to the target address. The router does not need to verify each message that is sent on the link. A value of 'true' means that users may send messages to any address. Allowing anonymous senders can also decrease performance: if [...]
+ },
+ maxReceivers: {
+ default: 2147483647,
+ type: "integer",
+ description:
+ "The maximum number of receiving links that may be created on this connection. A value of '0' disables all receiver links."
+ },
+ users: {
+ required: true,
+ type: "string",
+ description:
+ "A list of authenticated users for this user group. Use commas to separate multiple users. A user may belong to only one vhost user group."
+ },
+ sourcePattern: {
+ type: "string",
+ description:
+ "A wildcarded pattern for matching source addresses from which users in this group may receive messages. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match has the highest precedence. To specify mul [...]
+ },
+ allowWaypointLinks: {
+ default: true,
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to claim 'waypoint.N' capability for attached links. This allows endpoints to act as waypoints without needing auto-links."
+ },
+ maxSessionWindow: {
+ default: 1638400,
+ type: "integer",
+ description:
+ "The incoming capacity for new AMQP sessions, measured in octets. Non-zero policy values overwrite values specified for a listener object (AMQP Begin, incoming-window)."
+ },
+ allowUserIdProxy: {
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to send messages with a user ID that is different than the connection's authenticated user name."
+ },
+ maxFrameSize: {
+ default: 16384,
+ type: "integer",
+ description:
+ "The largest frame, in bytes, that may be sent on this connection. Non-zero policy values overwrite values specified for a listener object (AMQP Open, max-frame-size)."
+ },
+ targets: {
+ type: "string",
+ description:
+ "A list of target addresses to which users in this group may send messages. To specify multiple addresses, separate the addresses with either a comma or a space. If you do not specify any addresses, users in this group are not allowed to send messages to any addresses. You can use the substitution token '${user}' to specify an address that contains a user's authenticated user name. You can use an asterisk ('*') wildcard to match one or more characters in an address. However, [...]
+ },
+ sources: {
+ type: "string",
+ description:
+ "A list of source addresses from which users in this group may receive messages. To specify multiple addresses, separate the addresses with either a comma or a space. If you do not specify any addresses, users in this group are not allowed to receive messages from any addresses. You can use the substitution token '${user}' to specify an address that contains a user's authenticated user name. You can use an asterisk ('*') wildcard to match one or more characters in an address. [...]
+ },
+ allowAdminStatusUpdate: {
+ default: true,
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to update the admin status of other connections. Note: Inter-router connections cannot be deleted at any time."
+ },
+ allowDynamicLinkRoutes: {
+ default: true,
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to dynamically create connection-scoped link route destinations."
+ },
+ allowDynamicSource: {
+ type: "boolean",
+ description:
+ "Whether this connection is allowed to create dynamic receiving links (links to resources that do not exist on the peer). A value of 'true' means that users are able to automatically create resources on the peer system."
+ },
+ remoteHosts: {
+ required: true,
+ type: "string",
+ description:
+ "A list of remote hosts from which the users may connect. A host can be a hostname, IP address, or IP address range. Use commas to separate multiple hosts. To allow access from all remote hosts, specify a wildcard '*'. To deny access from all remote hosts, leave this attribute blank."
+ },
+ maxSenders: {
+ default: 2147483647,
+ type: "integer",
+ description:
+ "The maximum number of sending links that may be created on this connection. A value of '0' disables all sender links."
+ },
+ targetPattern: {
+ type: "string",
+ description:
+ "A wildcarded pattern for matching target addresses to which users in this group may send messages. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match has the highest precedence. To specify multiple [...]
+ },
+ maxSessions: {
+ default: 32768,
+ type: "integer",
+ description:
+ "The maximum number of sessions that may be created on this connection. Non-zero policy values overwrite values specified for a listener object (AMQP Open, channel-max)."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.vhostUserGroupSettings",
+ description:
+ "Policy settings for users connecting to a vhost. Configuration files including this section must use .json format."
+ },
+ vhostStats: {
+ operations: ["READ"],
+ attributes: {
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ perHostState: {
+ type: "map",
+ description:
+ "A map where the key is the host name and the value is a list of the host's connections."
+ },
+ hostname: {
+ type: "string",
+ description: "The vhost name."
+ },
+ perUserState: {
+ type: "map",
+ description:
+ "A map where the key is the authenticated user name and the value is a list of the user's connections."
+ },
+ sessionDenied: {
+ graph: true,
+ type: "integer"
+ },
+ connectionsApproved: {
+ graph: true,
+ type: "integer"
+ },
+ receiverDenied: {
+ graph: true,
+ type: "integer"
+ },
+ connectionsCurrent: {
+ graph: true,
+ type: "integer"
+ },
+ senderDenied: {
+ graph: true,
+ type: "integer"
+ },
+ connectionsDenied: {
+ graph: true,
+ type: "integer"
+ },
+ id: {
+ type: "string",
+ description: "The vhost name. DEPRECATED - use 'hostname' instead."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.vhostStats",
+ description: "Virtual host connection and access statistics."
+ },
+ connector: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ stripAnnotations: {
+ default: "both",
+ type: ["in", "out", "both", "no"],
+ description:
+ "['in', 'out', 'both', 'no'] in: Strip the dispatch router specific annotations only on ingress; out: Strip the dispatch router specific annotations only on egress; both: Strip the dispatch router specific annotations on both ingress and egress; no - do not strip dispatch router specific annotations"
+ },
+ saslUsername: {
+ type: "string",
+ description: "The user name that the connector is using to connect to a peer."
+ },
+ allowRedirect: {
+ default: true,
+ type: "boolean",
+ description: "Allow the peer to redirect this connection to another address."
+ },
+ idleTimeoutSeconds: {
+ default: 16,
+ type: "integer",
+ description:
+ "The idle timeout, in seconds, for connections through this connector. If no frames are received on the connection for this time interval, the connection shall be closed."
+ },
+ maxSessionFrames: {
+ type: "integer",
+ description:
+ "Session incoming window measured in transfer frames for sessions created on this connection. This is the number of transfer frames that may simultaneously be in flight for all links in the session. Setting this value to zero selects the default session window size. Policy settings will not overwrite this value. The numerical product of maxFrameSize and maxSessionFrames may not exceed 2^31-1. If (maxFrameSize x maxSessionFrames) exceeds 2^31-1 then maxSessionFrames is reduced [...]
+ },
+ cost: {
+ default: 1,
+ type: "integer",
+ description:
+ "For the 'inter-router' role only. This value assigns a cost metric to the inter-router connection. The default (and minimum) value is one. Higher values represent higher costs. The cost is used to influence the routing algorithm as it attempts to use the path with the lowest total cost from ingress to egress."
+ },
+ port: {
+ default: "amqp",
+ type: "string",
+ description: "Port number or symbolic service name."
+ },
+ policyVhost: {
+ type: "string",
+ description:
+ "A connector may optionally define a policy to restrict the remote container to access only specific resources. This attribute defines the name of the policy vhost for this connector. Within the vhost the connector will use the vhost policy settings from user group '$connector'. If the vhost policy is absent or if the user group '$connector' within that policy is absent then the connector will fail to start. In policy specified via connector attribute 'policyVhost' the follo [...]
+ },
+ saslMechanisms: {
+ type: "string",
+ description: "Space separated list of accepted SASL authentication mechanisms."
+ },
+ linkCapacity: {
+ type: "integer",
+ description:
+ "The capacity of links within this connection, in terms of message deliveries. The capacity is the number of messages that can be in-flight concurrently for each link."
+ },
+ role: {
+ default: "normal",
+ type: ["normal", "inter-router", "route-container", "edge"],
+ description:
+ "The role of an established connection. In the normal role, the connection is assumed to be used for AMQP clients that are doing normal message delivery over the connection. In the inter-router role, the connection is assumed to be to another router in the network. Inter-router discovery and routing protocols can only be used over inter-router connections. route-container role can be used for router-container connections, for example, a router-broker connection. In the edg [...]
+ },
+ saslPassword: {
+ type: "string",
+ description: "The password that the connector is using to connect to a peer."
+ },
+ maxSessions: {
+ default: 32768,
+ type: "integer",
+ description:
+ "The maximum number of sessions that can be simultaneously active on the connection. Setting this value to zero selects the default number of sessions. Policy settings will not overwrite this value. Defaults to 32768."
+ },
+ messageLoggingComponents: {
+ default: "none",
+ type: "string",
+ description:
+ "A comma separated list that indicates which components of the message should be logged (no spaces allowed between list components). Defaults to 'none' (log nothing). If you want all properties and application properties of the message logged use 'all'. Specific components of the message can be logged by indicating the components via a comma separated list. The components are message-id, user-id, to, subject, reply-to, correlation-id, content-type, content-encoding, absolute- [...]
+ },
+ host: {
+ default: "127.0.0.1",
+ type: "string",
+ description: "IP address: ipv4 or ipv6 literal or a host name"
+ },
+ protocolFamily: {
+ type: ["IPv4", "IPv6"],
+ description:
+ "['IPv4', 'IPv6'] IPv4: Internet Protocol version 4; IPv6: Internet Protocol version 6. If not specified, the protocol family will be automatically determined from the address."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ verifyHostname: {
+ default: true,
+ type: "boolean",
+ description:
+ "yes: Ensures that when initiating a connection (as a client) the host name in the URL to which this connector connects to matches the host name in the digital certificate that the peer sends back as part of the SSL connection; no: Does not perform host name verification"
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ maxFrameSize: {
+ default: 16384,
+ type: "integer",
+ description:
+ "The maximum frame size in octets that will be used in the connection-open negotiation with a connected peer. The frame size is the largest contiguous set of uninterrupted data that can be sent for a message delivery over the connection. Interleaving of messages on different links is done at frame granularity. Policy settings will not overwrite this value. Defaults to 16384."
+ },
+ sslProfile: {
+ type: "string",
+ description: "Name of the sslProfile."
+ },
+ failoverUrls: {
+ type: "string",
+ description: "A read-only, comma-separated list of failover urls. "
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.connector",
+ description: "Establishes an outgoing connection from the router."
+ },
+ logStats: {
+ operations: ["READ"],
+ attributes: {
+ debugCount: {
+ graph: true,
+ type: "integer",
+ description: "How many debug-level events have happened on this log."
+ },
+ criticalCount: {
+ graph: true,
+ type: "integer",
+ description: "How many critical-level events have happened on this log."
+ },
+ traceCount: {
+ graph: true,
+ type: "integer",
+ description: "How many trace-level events have happened on this log."
+ },
+ warningCount: {
+ graph: true,
+ type: "integer",
+ description: "How many warning-level events have happened on this log."
+ },
+ infoCount: {
+ graph: true,
+ type: "integer",
+ description: "How many info-level events have happened on this log."
+ },
+ noticeCount: {
+ graph: true,
+ type: "integer",
+ description: "How many notice-level events have happened on this log."
+ },
+ errorCount: {
+ graph: true,
+ type: "integer",
+ description: "How many error-level events have happened on this log."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.logStats",
+ description: "histogram of the different severity-levels of events on the given log."
+ },
+ configurationEntity: {
+ operations: ["READ"],
+ attributes: {
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.configurationEntity",
+ description: "Base type for entities containing configuration information."
+ },
+ exchange: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ divertedCount: {
+ type: "integer",
+ description:
+ "A count of those deliveries that were forwarded via the alternateAddress only. This is a subset of the forwardedCount."
+ },
+ alternatePhase: {
+ type: "integer",
+ description: "The address phase for the alternateAddress. Defaults to '0'."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ matchMethod: {
+ default: "amqp",
+ type: ["amqp", "mqtt"],
+ description:
+ "Key matching algorithm used. 'amqp' uses the legacy AMQP topic exchange wildcard match method as described in the pre-1.0 drafts. 'mqtt' uses the MQTT topic filter wildcard match method."
+ },
+ forwardedCount: {
+ type: "integer",
+ description:
+ "The total number of deliveries forwarded via matched bindings or to the alternateAddress"
+ },
+ receivedCount: {
+ type: "integer",
+ description: "The total number of deliveries received by this exchange."
+ },
+ bindingCount: {
+ type: "integer",
+ description: "The number of bindings associated with this exchange."
+ },
+ address: {
+ required: true,
+ type: "string",
+ description:
+ "The address of the exchange. Used by the message publisher as the target for sending messages."
+ },
+ phase: {
+ type: "integer",
+ description: "The address phase for the exchange. Defaults to '0'."
+ },
+ alternateAddress: {
+ type: "string",
+ description: "The address to forward the message to if no bindings are matched."
+ },
+ droppedCount: {
+ type: "integer",
+ description:
+ "The total number of deliveries dropped due to the lack of an outgoing subscription."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.config.exchange",
+ description: "[EXPERIMENTAL] Defines a topic exchange."
+ },
+ listener: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ stripAnnotations: {
+ default: "both",
+ type: ["in", "out", "both", "no"],
+ description:
+ "['in', 'out', 'both', 'no'] in: Strip the dispatch router specific annotations only on ingress; out: Strip the dispatch router specific annotations only on egress; both: Strip the dispatch router specific annotations on both ingress and egress; no - do not strip dispatch router specific annotations"
+ },
+ requireSsl: {
+ type: "boolean",
+ description:
+ "yes: Require the use of SSL or TLS on the connection; no: Allow clients to connect without SSL or TLS."
+ },
+ idleTimeoutSeconds: {
+ default: 16,
+ type: "integer",
+ description:
+ "The idle timeout, in seconds, for connections through this listener. If no frames are received on the connection for this time interval, the connection shall be closed."
+ },
+ maxSessionFrames: {
+ type: "integer",
+ description:
+ "Session incoming window measured in transfer frames for sessions created on this connection. This is the number of transfer frames that may simultaneously be in flight for all links in the session. Setting this value to zero selects the default session window size. Policy settings, if specified, will overwrite this value. The numerical product of maxFrameSize and maxSessionFrames may not exceed 2^31-1. If (maxFrameSize x maxSessionFrames) exceeds 2^31-1 then maxSessionFrames [...]
+ },
+ cost: {
+ default: 1,
+ type: "integer",
+ description:
+ "For the 'inter-router' role only. This value assigns a cost metric to the inter-router connection. The default (and minimum) value is one. Higher values represent higher costs. The cost is used to influence the routing algorithm as it attempts to use the path with the lowest total cost from ingress to egress."
+ },
+ port: {
+ default: "amqp",
+ type: "string",
+ description:
+ "Port number or symbolic service name. If '0', the router shall assign an ephemeral port to the listener and log the port number with a log of the form 'SERVER (notice) Listening on <host>:<assigned-port> (<listener-name>)'"
+ },
+ saslPlugin: {
+ type: "string",
+ description:
+ "EXPERIMENTAL. Name of the a sasl plugin configuration section to use for this listener (e.g. authServicePlugin)."
+ },
+ linkCapacity: {
+ type: "integer",
+ description:
+ "The capacity of links within this connection, in terms of message deliveries. The capacity is the number of messages that can be in-flight concurrently for each link."
+ },
+ policyVhost: {
+ type: "string",
+ description:
+ "A listener may optionally define a virtual host to index to a specific policy to restrict the remote container to access only specific resources. This attribute defines the name of the policy vhost for this listener. If multi-tenancy is enabled for the listener, this vhost will override the peer-supplied vhost for the purposes of identifying the desired policy settings for the connections."
+ },
+ saslMechanisms: {
+ type: "string",
+ description: "Space separated list of accepted SASL authentication mechanisms."
+ },
+ requireEncryption: {
+ type: "boolean",
+ description:
+ "yes: Require the connection to the peer to be encrypted; no: Permit non-encrypted communication with the peer"
+ },
+ trustedCertsFile: {
+ type: "path",
+ description:
+ "This optional setting can be used to reduce the set of available CAs for client authentication. If used, this setting must provide the absolute path to a PEM file that contains the trusted certificates."
+ },
+ role: {
+ default: "normal",
+ type: ["normal", "inter-router", "route-container", "edge"],
+ description:
+ "The role of an established connection. In the normal role, the connection is assumed to be used for AMQP clients that are doing normal message delivery over the connection. In the inter-router role, the connection is assumed to be to another router in the network. Inter-router discovery and routing protocols can only be used over inter-router connections. route-container role can be used for router-container connections, for example, a router-broker connection. In the edg [...]
+ },
+ websockets: {
+ default: true,
+ type: "boolean",
+ description:
+ "For an http enabled listener, determines whether websockets access is enabled (true by default)."
+ },
+ maxSessions: {
+ default: 32768,
+ type: "integer",
+ description:
+ "The maximum number of sessions that can be simultaneously active on the connection. Setting this value to zero selects the default number of sessions. Policy settings, if specified, will overwrite this value. Defaults to 32768."
+ },
+ authenticatePeer: {
+ type: "boolean",
+ description:
+ "yes: Require the peer's identity to be authenticated; no: Do not require any authentication."
+ },
+ http: {
+ type: "boolean",
+ description:
+ "Accept HTTP connections that can upgrade to AMQP over WebSocket. Plain AMQP connections are not accepted on this listener."
+ },
+ messageLoggingComponents: {
+ default: "none",
+ type: "string",
+ description:
+ "A comma separated list that indicates which components of the message should be logged. Defaults to 'none' (log nothing). If you want all properties and application properties of the message logged use 'all'. Specific components of the message can be logged by indicating the components via a comma separated list. The components are message-id, user-id, to, subject, reply-to, correlation-id, content-type, content-encoding, absolute-expiry-time, creation-time, group-id, group- [...]
+ },
+ multiTenant: {
+ type: "boolean",
+ description:
+ "If true, apply multi-tenancy to endpoints connected at this listener. The address space is defined by the virtual host (hostname field in the Open)."
+ },
+ metrics: {
+ default: true,
+ type: "boolean",
+ description:
+ "Export metrics in prometheus text format for the router (using path /metrics). Assumes listener is enabled for http."
+ },
+ host: {
+ type: "string",
+ description:
+ "A host name, IPV4 or IPV6 literal, or the empty string. The empty string listens on all local addresses. A host name listens on all addresses associated with the name. An IPV6 literal address (or wildcard '[::]') listens only for IPV6. An IPV4 literal address (or wildcard '0.0.0.0') listens only for IPV4."
+ },
+ initialHandshakeTimeoutSeconds: {
+ type: "integer",
+ description:
+ "The timeout, in seconds, for the initial handshake for connections coming in through listeners. If the time interval expires before the peer sends the AMQP OPEN frame, the connection shall be closed. A value of zero (the default) disables this timeout."
+ },
+ httpRootDir: {
+ type: "path",
+ description:
+ "Absolute path to a directory from which to serve static HTML files. For example, /usr/share/qpid-dispatch/console."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ socketAddressFamily: {
+ type: ["IPv4", "IPv6"],
+ description:
+ "['IPv4', 'IPv6'] IPv4: Internet Protocol version 4; IPv6: Internet Protocol version 6. If not specified, the protocol family will be automatically determined from the address."
+ },
+ healthz: {
+ default: true,
+ type: "boolean",
+ description:
+ "Provide a simple HTTP based liveness test (using path /healthz). Assumes listener is enabled for http."
+ },
+ maxFrameSize: {
+ default: 16384,
+ type: "integer",
+ description:
+ "The maximum frame size in octets that will be used in the connection-open negotiation with a connected peer. The frame size is the largest contiguous set of uninterrupted data that can be sent for a message delivery over the connection. Interleaving of messages on different links is done at frame granularity. Policy settings, if specified, will overwrite this value. Defaults to 16384."
+ },
+ sslProfile: {
+ type: "string",
+ description: "Name of the sslProfile."
+ },
+ failoverUrls: {
+ type: "string",
+ description:
+ "A comma-separated list of failover urls to be supplied to connected clients. Form: [(amqp|amqps|ws|wss)://]host_or_ip[:port]"
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.listener",
+ description: "Listens for incoming connections to the router."
+ },
+ policy: {
+ operations: ["READ"],
+ attributes: {
+ enableVhostNamePatterns: {
+ type: "boolean",
+ description:
+ "Enable vhost name patterns. When false vhost hostnames are treated as literal strings. When true vhost hostnames are treated as match patterns."
+ },
+ connectionsProcessed: {
+ graph: true,
+ type: "integer"
+ },
+ policyDir: {
+ type: "path",
+ description:
+ "The absolute path to a directory that holds vhost policy definition files in JSON format (*.json). The router processes all of the vhost policies in each JSON file that is in this directory."
+ },
+ defaultVhost: {
+ default: "$default",
+ type: "string",
+ description:
+ "The name of the default vhost policy. This policy rule set is applied to a connection for which a vhost policy has not otherwise been configured. Processing for the default vhost is enabled by default and set to select vhost '$default'. To disable default vhost processing set defaultVhost to blank or do not define a vhost named '$default'."
+ },
+ connectionsDenied: {
+ graph: true,
+ type: "integer"
+ },
+ enableVhostPolicy: {
+ type: "boolean",
+ description:
+ "Enables the router to enforce the connection denials and resource limits defined in the configured vhost policies."
+ },
+ maxConnections: {
+ default: 65535,
+ type: "integer",
+ description:
+ "The maximum number of concurrent client connections allowed for this router. This limit is always enforced, even if no other policy settings have been defined. The limit is applied to all incoming connections regardless of remote host, authenticated user, or targeted vhost."
+ },
+ connectionsCurrent: {
+ graph: true,
+ type: "integer"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ singleton: true,
+ fullyQualifiedType: "org.apache.qpid.dispatch.policy",
+ description: "Defines global connection limit"
+ },
+ address: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ egressPhase: {
+ type: "integer",
+ description: "Advanced - Override the egress phase for this address"
+ },
+ pattern: {
+ type: "string",
+ description:
+ "A wildcarded pattern for address matching. Incoming addresses are matched against this pattern. Matching addresses use the configured settings. The pattern consists of one or more tokens separated by a forward slash '/'. A token can be one of the following: a * character, a # character, or a sequence of characters that do not include /, *, or #. The * token matches any single token. The # token matches zero or more tokens. * has higher precedence than #, and exact match ha [...]
+ },
+ ingressPhase: {
+ type: "integer",
+ description: "Advanced - Override the ingress phase for this address"
+ },
+ priority: {
+ type: "integer",
+ description:
+ "All messages sent to this address which lack an intrinsic priority will be assigned this priority."
+ },
+ enableFallback: {
+ type: "boolean",
+ description:
+ "If false, undeliverable messages are released. If true, undeliverable messages shall be re-delivered to a fallback destination. The fallback destination uses the same address, but is attached using an autoLink with 'fallback' enabled or a link with the qd.fallback capability."
+ },
+ prefix: {
+ type: "string",
+ description:
+ "The address prefix for the configured settings. Cannot be used with a pattern attribute."
+ },
+ waypoint: {
+ type: "boolean",
+ description:
+ "Designates this address space as being used for waypoints. This will cause the proper address-phasing to be used."
+ },
+ distribution: {
+ default: "balanced",
+ type: ["multicast", "closest", "balanced", "unavailable"],
+ description: "Treatment of traffic associated with the address"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.config.address",
+ description:
+ "Entity type for address configuration. This is used to configure the treatment of message-routed deliveries within a particular address-space. The configuration controls distribution and address phasing."
+ },
+ authServicePlugin: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ realm: {
+ type: "string",
+ description: "Value to set for hostname field on sasl-init"
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ host: {
+ type: "string",
+ description: "A host name, IPV4 or IPV6 literal, of the service to delegate to."
+ },
+ sslProfile: {
+ type: "string",
+ description: "Name of the sslProfile to use for the authentication service."
+ },
+ port: {
+ default: "amqp",
+ type: "string",
+ description: "Port number of the service delegated host."
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.authServicePlugin",
+ description: "EXPERIMENTAL. Attributes for setting SASL plugin."
+ },
+ "router.node": {
+ operations: ["READ"],
+ attributes: {
+ routerLink: {
+ type: "entityId",
+ description: "Local link to remote node"
+ },
+ nextHop: {
+ type: "string",
+ description: "Neighbour ID of next hop to remote node from here."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ index: {
+ type: "integer",
+ description:
+ "Index number used in statistics histograms for this router node. This index is specific to this router."
+ },
+ validOrigins: {
+ type: "list",
+ description:
+ "List of valid origin nodes for messages arriving via the re mote node, used for duplicate elimination in redundant networks."
+ },
+ linkState: {
+ type: "list",
+ description: "List of remote node's neighbours."
+ },
+ instance: {
+ type: "integer",
+ description: "Remote node boot number."
+ },
+ cost: {
+ type: "integer",
+ description: "Reachability cost"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ protocolVersion: {
+ type: "integer",
+ description: "Router-protocol version supported by the node."
+ },
+ lastTopoChange: {
+ type: "integer",
+ description: "Timestamp showing the most recent change to this node's neighborhood."
+ },
+ id: {
+ type: "string",
+ description: "Remote node identifier."
+ },
+ address: {
+ type: "string",
+ description: "Address of the remote node"
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.node",
+ description: "Remote router node connected to this router."
+ },
+ autoLink: {
+ operations: ["CREATE", "DELETE", "READ"],
+ attributes: {
+ operStatus: {
+ type: ["inactive", "attaching", "failed", "active", "quiescing", "idle"],
+ description:
+ "The operational status of this autoLink: inactive - The remote container is not connected; attaching - the link is attaching to the remote node; failed - the link attach failed; active - the link is attached and operational; quiescing - the link is transitioning to idle state; idle - the link is attached but there are no deliveries flowing and no unsettled deliveries."
+ },
+ direction: {
+ required: true,
+ type: ["in", "out"],
+ description:
+ "The direction of the link to be created. In means into the router, out means out of the router."
+ },
+ containerId: {
+ type: "string",
+ description:
+ "ContainerID for the target container. Only one of containerId or connection should be specified for an autoLink. Specifying both will result in the autoLink not being created"
+ },
+ linkRef: {
+ type: "string",
+ description: "Reference to the org.apache.qpid.dispatch.router.link if the link exists"
+ },
+ externalAddress: {
+ type: "string",
+ description:
+ "If present, an alternate address of the node on the remote container. This is used if the node has a different address than the address used internally by the router to route deliveries."
+ },
+ connection: {
+ type: "string",
+ description:
+ "The name from a connector or listener. Only one of containerId or connection should be specified for an autoLink. Specifying both will result in the autoLink not being created"
+ },
+ address: {
+ required: true,
+ type: "string",
+ description: "The address of the provisioned object"
+ },
+ phase: {
+ type: "integer",
+ description:
+ "The address phase for this link. Defaults to '0' for 'out' links and '1' for 'in' links."
+ },
+ fallback: {
+ type: "boolean",
+ description:
+ "If true, this auto-link is attached to a fallback destination for an address."
+ },
+ lastError: {
+ type: "string",
+ description: "The error description from the last attach failure"
+ },
+ identity: {
+ unique: true,
+ type: "string",
+ description: "Unique identity generated by the system. Will not change."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ }
+ },
+ fullyQualifiedType: "org.apache.qpid.dispatch.router.config.autoLink",
+ description:
+ "Entity type for configuring auto-links. Auto-links are links whose lifecycle is managed by the router. These are typically used to attach to waypoints on remote containers (brokers, etc.)."
+ },
+ "router.address": {
+ operations: ["READ"],
+ attributes: {
+ subscriberCount: {
+ graph: true,
+ type: "integer",
+ description:
+ "The number of local subscribers for this address (i.e. attached to this router)"
+ },
+ deliveriesEgress: {
+ graph: true,
+ type: "integer",
+ description:
+ "The number of deliveries to this address that exited the router network on this router"
+ },
+ deliveriesEgressRouteContainer: {
+ graph: true,
+ type: "integer",
+ description: "Number of deliveries that were sent to a route-container address."
+ },
+ name: {
+ unique: true,
+ type: "string",
+ description: "Unique name optionally assigned by user. Can be changed."
+ },
+ deliveriesIngress: {
+ graph: true,
+ type: "integer",
+ description:
+ "The number of deliveries to this address that entered the router network on this router"
+ },
+ transitOutstanding: {
+ type: "list",
+ description:
+ "List of numbers of outstanding deliveries across a transit (inter-router) link for this address. This is for balanced distribution only."
+ },
+ deliveriesIngressRouteContainer: {
+ graph: true,
+ type: "integer",
+ description: "Number of deliveries that were received from a route-container address."
+ },
+ priority: {
+ type: "integer",
+ description: "The message priority being handled by this address."
+ },
+ remoteCount: {
+ graph: true,
+ type: "integer",
+ description:
+ "The number of remote routers that have at least one subscriber to this address"
+ },
+ inProcess: {
+ type: "integer",
+ description: "The number of in-process subscribers for this address"
+ },
+ deliveriesFromContainer: {
+ graph: true,
+ type: "integer",
+ description:
+ "The number of deliveries to this address that were originated from an in-process entity"
+ },
+ deliveriesTransit: {
+ graph: true,
+ type: "integer",
+ description:
+ "The number of deliveries to this address that transited this router to another router"
+ },
+ containerCount: {
+ graph: true,
+ type: "integer",
+ description: "The number of attached containers that serve this route address"
+ },
+ key: {
+ type: "string",
+ description: "Internal unique (to this router) key to identify the address"
+ },
+ deliveriesRedirectedToFallback: {
+ graph: true,
... 734 lines suppressed ...
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org