From 9d44ac9cd52a7f287727c66327e39da9109465ac Mon Sep 17 00:00:00 2001
From: Tom Gross <itconsense@gmail.com>
Date: Mon, 2 Dec 2019 11:30:16 +0100
Subject: [PATCH] Add getter for cluster config
---
.../cluster/jms/ClusterAdminControllerCluster.java | 4 ++--
.../commons/coordinate/cluster/jms/ClusterEventBus.java | 6 +++++-
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterAdminControllerCluster.java b/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterAdminControllerCluster.java
index b019b3a3be7..32a2caa9614 100644
--- a/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterAdminControllerCluster.java
+++ b/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterAdminControllerCluster.java
@@ -118,7 +118,7 @@ public class ClusterAdminControllerCluster extends BasicController {
mainVc = createVelocityContainer("cluster");
// information about the cluster nodes
- mainVc.contextPut("own_nodeid", "This node is node: '"+clusBus.clusterConfig.getNodeId()+"'");
+ mainVc.contextPut("own_nodeid", "This node is node: '"+clusBus.getClusterConfig().getNodeId()+"'");
nodeInfoVc = createVelocityContainer("nodeinfos");
Formatter f = Formatter.getInstance(ureq.getLocale());
@@ -196,7 +196,7 @@ public class ClusterAdminControllerCluster extends BasicController {
return o1.getNodeId().compareTo(o2.getNodeId());
}});
nodeInfoVc.contextPut("stats",li);
- nodeInfoVc.contextPut("thisNodeId", clusBus.clusterConfig.getNodeId());
+ nodeInfoVc.contextPut("thisNodeId", clusBus.getClusterConfig().getNodeId());
mainVc.contextPut("eventBusListener", clusBus.toString());
mainVc.contextPut("busListenerInfos", clusBus.getBusInfosAsString());
}
diff --git a/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterEventBus.java b/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterEventBus.java
index 804cd512921..faaca9badbb 100644
--- a/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterEventBus.java
+++ b/src/main/java/org/olat/commons/coordinate/cluster/jms/ClusterEventBus.java
@@ -467,7 +467,11 @@ public class ClusterEventBus extends AbstractEventBus implements MessageListener
log.warn("Exception in stop ClusteredSearchProvider, ",e);
}
}
-
+
+ public ClusterConfig getClusterConfig() {
+ return clusterConfig;
+ }
+
/**
* [used by spring]
*/
--
GitLab