modules/common/cassandra-common/src/main/java/org/rhq/cassandra/DeploymentOptions.java |
25 ++++++++++
1 file changed, 25 insertions(+)
New commits:
commit de51bc89eb7f7f128a30d5c7468361b1bc485e82
Author: John Sanda <jsanda(a)redhat.com>
Date: Thu Nov 29 11:42:19 2012 -0500
adding config properties from previous commit to DeploymentOptions
diff --git
a/modules/common/cassandra-common/src/main/java/org/rhq/cassandra/DeploymentOptions.java
b/modules/common/cassandra-common/src/main/java/org/rhq/cassandra/DeploymentOptions.java
index 831ee3f..7f77316 100644
---
a/modules/common/cassandra-common/src/main/java/org/rhq/cassandra/DeploymentOptions.java
+++
b/modules/common/cassandra-common/src/main/java/org/rhq/cassandra/DeploymentOptions.java
@@ -49,6 +49,8 @@ public class DeploymentOptions {
private String loggingLevel;
private Long ringDelay;
private Integer numTokens;
+ private Integer nativeTransportPort;
+ private Integer nativeTransportMaxThreads;
public DeploymentOptions() {
}
@@ -97,6 +99,9 @@ public class DeploymentOptions {
}
setNumTokens(Integer.valueOf(loadProperty("rhq.cassandra.node.num-tokens",
properties)));
+
setNativeTransportPort(Integer.valueOf(loadProperty("rhq.cassandra.native-transport-port",
properties)));
+
setNativeTransportMaxThreads(Integer.valueOf(loadProperty("rhq.casandra.node.native-transport-max-threads",
+ properties)));
}
private String loadProperty(String key, Properties properties) {
@@ -207,4 +212,24 @@ public class DeploymentOptions {
}
}
+ public Integer getNativeTransportPort() {
+ return nativeTransportPort;
+ }
+
+ public void setNativeTransportPort(Integer port) {
+ if (nativeTransportPort == null) {
+ nativeTransportPort = port;
+ }
+ }
+
+ public Integer getNativeTransportMaxThreads() {
+ return nativeTransportMaxThreads;
+ }
+
+ public void setNativeTransportMaxThreads(int numThreads) {
+ if (nativeTransportMaxThreads == null) {
+ nativeTransportMaxThreads = numThreads;
+ }
+ }
+
}
Show replies by date