You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/12/14 13:55:13 UTC
[activemq-artemis] 04/04: ARTEMIS-3570 also decode routing-types
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit de7d1413972fc92cc2f536866b86eec54bd52d14
Author: Erwin Dondorp <er...@cgi.com>
AuthorDate: Wed Dec 1 10:17:15 2021 +0100
ARTEMIS-3570 also decode routing-types
---
.../src/main/webapp/plugin/js/components/browse.js | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js
index 8527b79..71f0d60 100644
--- a/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js
+++ b/artemis-hawtio/artemis-plugin/src/main/webapp/plugin/js/components/browse.js
@@ -826,6 +826,14 @@ var Artemis;
return enc > -1 && enc < 9 ? amqpEncodingLabels[enc] : enc;
}
+ var routingTypes = ["multicast", "anycast"];
+ function formatRoutingType(rt) {
+ if (isNaN(rt) || typeof rt !== "number") {
+ return enc;
+ }
+ return rt > -1 && rt < 2 ? routingTypes[rt] : rt;
+ }
+
function createProperties(message) {
var properties = [];
angular.forEach(message, function (value, key) {
@@ -839,6 +847,10 @@ var Artemis;
v2 += " (" + formatAmqpEncoding(v2) + ")";
} else if(k2 === "_AMQ_NotifTimestamp") {
v2 += " (" + formatTimestamp(v2) + ")";
+ } else if(k2 === "_AMQ_ROUTING_TYPE") {
+ v2 += " (" + formatRoutingType(v2) + ")";
+ } else if(k2 === "_AMQ_ORIG_ROUTING_TYPE") {
+ v2 += " (" + formatRoutingType(v2) + ")";
} else if(k2 === "extraProperties._AMQ_ACTUAL_EXPIRY") {
v2 += " (" + formatTimestamp(v2) + ")";
} else if(k2 === "messageAnnotations.x-opt-ACTUAL-EXPIRY") {