From 6958d627983c66813ad12f0e7b42619ddbdfe7b0 Mon Sep 17 00:00:00 2001 From: John Sanda Date: Fri, 26 Sep 2014 11:25:50 -0400 Subject: [PATCH] [BZ 1108095] fix compiler errors --- .../server/storage/StorageClientManager.java | 1 - .../server/storage/StorageClusterMonitor.java | 11 ----------- 2 files changed, 12 deletions(-) diff --git a/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManager.java b/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManager.java index 49f4dfe33be..8428bab722c 100644 --- a/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManager.java +++ b/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClientManager.java @@ -179,7 +179,6 @@ public synchronized boolean init() { session = new StorageSession(wrappedSession); storageClusterMonitor = new StorageClusterMonitor(session); - storageClusterMonitor.updateRequestLimit(); session.addStorageStateListener(storageClusterMonitor); metricsConfiguration = new MetricsConfiguration(); diff --git a/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClusterMonitor.java b/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClusterMonitor.java index ffec60a0370..673a55bc14c 100644 --- a/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClusterMonitor.java +++ b/modules/enterprise/server/jar/src/main/java/org/rhq/enterprise/server/storage/StorageClusterMonitor.java @@ -1,7 +1,5 @@ package org.rhq.enterprise.server.storage; -import static org.rhq.server.metrics.StorageClientConstants.REQUEST_LIMIT; - import java.net.InetAddress; import com.datastax.driver.core.exceptions.NoHostAvailableException; @@ -9,7 +7,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.rhq.enterprise.server.util.LookupUtil; import org.rhq.server.metrics.StorageSession; import org.rhq.server.metrics.StorageStateListener; @@ -36,19 +33,16 @@ public boolean isClusterAvailable() { public void onStorageNodeUp(InetAddress address) { log.info("Storage node at " + address.getHostAddress() + " is up"); isClusterAvailable = true; - updateRequestLimit(); } @Override public void onStorageNodeDown(InetAddress address) { log.info("Storage node at " + address.getHostAddress() + " is down"); - updateRequestLimit(); } @Override public void onStorageNodeRemoved(InetAddress address) { log.info("Storage node at " + address.getHostAddress() + " has been removed from the cluster"); - updateRequestLimit(); } @Override @@ -65,12 +59,7 @@ public void onStorageClusterDown(NoHostAvailableException e) { @Override public void onClientTimeout(NoHostAvailableException e) { - updateRequestLimit(); } - public void updateRequestLimit() { - StorageClientManager storageClientManager = LookupUtil.getStorageClientManager(); - storageClientManager.persistStorageProperty(REQUEST_LIMIT, Double.toString(session.getRequestLimit())); - } }