Revert "Adding missing method implementation"

This reverts commit 8e5d649048 in
preparation for Cassandra 3.x compatibility changes.
This commit is contained in:
Pekka Enberg 2016-11-09 11:03:07 +02:00
parent 8e5d649048
commit c08442b158
3 changed files with 8 additions and 27 deletions

View File

@ -137,7 +137,7 @@ public class CompactionManager implements CompactionManagerMBean {
@Deprecated @Deprecated
public long getTotalBytesCompacted() { public long getTotalBytesCompacted() {
log(" getTotalBytesCompacted()"); log(" getTotalBytesCompacted()");
return metrics.bytesCompacted.count(); return c.getLongValue("");
} }
/** /**
@ -187,11 +187,7 @@ public class CompactionManager implements CompactionManagerMBean {
*/ */
public int getCoreCompactorThreads() { public int getCoreCompactorThreads() {
log(" getCoreCompactorThreads()"); log(" getCoreCompactorThreads()");
/** return c.getIntValue("");
* Core size pool is meaningless, we still wants to return a valid reponse,
* just in case someone will try to call this method.
*/
return 1;
} }
/** /**
@ -209,11 +205,7 @@ public class CompactionManager implements CompactionManagerMBean {
*/ */
public int getMaximumCompactorThreads() { public int getMaximumCompactorThreads() {
log(" getMaximumCompactorThreads()"); log(" getMaximumCompactorThreads()");
/** return c.getIntValue("");
* Core size pool is meaningless, we still wants to return a valid reponse,
* just in case someone will try to call this method.
*/
return 1;
} }
/** /**
@ -231,11 +223,7 @@ public class CompactionManager implements CompactionManagerMBean {
*/ */
public int getCoreValidationThreads() { public int getCoreValidationThreads() {
log(" getCoreValidationThreads()"); log(" getCoreValidationThreads()");
/** return c.getIntValue("");
* Core validation size pool is meaningless, we still wants to return a valid reponse,
* just in case someone will try to call this method.
*/
return 1;
} }
/** /**
@ -253,11 +241,7 @@ public class CompactionManager implements CompactionManagerMBean {
*/ */
public int getMaximumValidatorThreads() { public int getMaximumValidatorThreads() {
log(" getMaximumValidatorThreads()"); log(" getMaximumValidatorThreads()");
/** return c.getIntValue("");
* Core validation size pool is meaningless, we still wants to return a valid reponse,
* just in case someone will try to call this method.
*/
return 1;
} }
/** /**

View File

@ -31,8 +31,6 @@ import javax.json.JsonArray;
import javax.json.JsonObject; import javax.json.JsonObject;
import javax.management.MBeanServer; import javax.management.MBeanServer;
import javax.management.ObjectName; import javax.management.ObjectName;
import javax.ws.rs.core.MultivaluedHashMap;
import javax.ws.rs.core.MultivaluedMap;
import org.apache.cassandra.metrics.DroppedMessageMetrics; import org.apache.cassandra.metrics.DroppedMessageMetrics;
@ -242,9 +240,7 @@ public final class MessagingService implements MessagingServiceMBean {
public int getVersion(String address) throws UnknownHostException { public int getVersion(String address) throws UnknownHostException {
log(" getVersion(String address) throws UnknownHostException"); log(" getVersion(String address) throws UnknownHostException");
MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>(); return c.getIntValue("");
queryParams.add("addr", address);
return c.getIntValue("/messaging_service/version", queryParams);
} }
} }

View File

@ -1446,7 +1446,8 @@ public class StorageService extends NotificationBroadcasterSupport
@Override @Override
public double getTracingProbability() { public double getTracingProbability() {
// TODO Auto-generated method stub
log(" getTracingProbability()"); log(" getTracingProbability()");
return c.getDoubleValue("/storage_service/trace_probability"); return c.getDoubleValue("");
} }
} }