* on a single line.
*/
private void defineMembers() {
- member = configDatastore.getActorContext().getCurrentMemberName().getName();
+ member = configDatastore.getActorUtils().getCurrentMemberName().getName();
log.info("defineMembers(): Cluster member: {}", member);
log.info("defineMembers(): Parsing akka.conf for cluster memberMap...");
* @deprecated No longer used since the refactor to use the HealthResolver
* pattern. Retained so the logic can be replicated later.
*/
+ @Deprecated
private void isolateSiteFromCluster(ArrayList<ClusterActor> activeSite, ArrayList<ClusterActor> standbySite, String port) {
log.info("isolateSiteFromCluster(): Halting Akka traffic...");
for(ClusterActor actor : standbySite) {
* @deprecated No longer used since the refactor to use the HealthResolver
* pattern. Retained so the logic can be replicated later.
*/
+ @Deprecated
private void downUnreachableNodes(ArrayList<ClusterActor> activeSite, ArrayList<ClusterActor> standbySite, String port) {
log.info("downUnreachableNodes(): Setting site unreachable...");
JSONObject jolokiaInput = new JSONObject();
* @deprecated No longer used since the refactor to use the HealthResolver
* pattern. Retained so the logic can be replicated later.
*/
+ @Deprecated
private void backupMdSal(ArrayList<ClusterActor> activeSite, String port) {
log.info("backupMdSal(): Backing up data...");
try {