github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

https://github.com/mrniko/redisson/pull/244

Browse Source 
Non-functional; rename config and connection manager class names
pull/244/head
Steve Ungerer 10 years ago
parent ad24fed86b
commit 985499bceb
4 changed files with 31 additions and 31 deletions
Show Stats Download Patch File Download Diff File

34
src/main/java/org/redisson/Config.java
Unescape Escape View File

@ -34,7 +34,7 @@ public class Config {
private ClusterServersConfig clusterServersConfig;
private ElasticacheReplicationGroupServersConfig elasticacheReplicationGroupServersConfig;
private ElasticacheServersConfig elasticacheServersConfig;
/**
* Threads amount shared between all redis node clients
@ -73,8 +73,8 @@ public class Config {
if (oldConf.getClusterServersConfig() != null ) {
setClusterServersConfig(new ClusterServersConfig(oldConf.getClusterServersConfig()));
}
if (oldConf.getElasticacheReplicationGroupServersConfig() != null) {
setElasticacheReplicationGroupServersConfig(new ElasticacheReplicationGroupServersConfig(oldConf.getElasticacheReplicationGroupServersConfig()));
if (oldConf.getElasticacheServersConfig() != null) {
setElasticacheServersConfig(new ElasticacheServersConfig(oldConf.getElasticacheServersConfig()));
}
}
@ -97,7 +97,7 @@ public class Config {
checkMasterSlaveServersConfig();
checkSentinelServersConfig();
checkSingleServerConfig();
checkElasticacheReplicationGroupServersConfig();
checkElasticacheServersConfig();
if (clusterServersConfig == null) {
clusterServersConfig = new ClusterServersConfig();
@ -112,30 +112,30 @@ public class Config {
this.clusterServersConfig = clusterServersConfig;
}
public ElasticacheReplicationGroupServersConfig useElasticacheReplicationGroupServers() {
public ElasticacheServersConfig useElasticacheServers() {
checkClusterServersConfig();
checkMasterSlaveServersConfig();
checkSentinelServersConfig();
checkSingleServerConfig();
if (elasticacheReplicationGroupServersConfig == null) {
elasticacheReplicationGroupServersConfig = new ElasticacheReplicationGroupServersConfig();
if (elasticacheServersConfig == null) {
elasticacheServersConfig = new ElasticacheServersConfig();
}
return elasticacheReplicationGroupServersConfig;
return elasticacheServersConfig;
}
ElasticacheReplicationGroupServersConfig getElasticacheReplicationGroupServersConfig() {
return elasticacheReplicationGroupServersConfig;
ElasticacheServersConfig getElasticacheServersConfig() {
return elasticacheServersConfig;
}
void setElasticacheReplicationGroupServersConfig(ElasticacheReplicationGroupServersConfig elasticacheReplicationGroupServersConfig) {
this.elasticacheReplicationGroupServersConfig = elasticacheReplicationGroupServersConfig;
void setElasticacheServersConfig(ElasticacheServersConfig elasticacheServersConfig) {
this.elasticacheServersConfig = elasticacheServersConfig;
}
public SingleServerConfig useSingleServer() {
checkClusterServersConfig();
checkMasterSlaveServersConfig();
checkSentinelServersConfig();
checkElasticacheReplicationGroupServersConfig();
checkElasticacheServersConfig();
if (singleServerConfig == null) {
singleServerConfig = new SingleServerConfig();
@ -154,7 +154,7 @@ public class Config {
checkClusterServersConfig();
checkSingleServerConfig();
checkMasterSlaveServersConfig();
checkElasticacheReplicationGroupServersConfig();
checkElasticacheServersConfig();
if (sentinelServersConfig == null) {
sentinelServersConfig = new SentinelServersConfig();
@ -173,7 +173,7 @@ public class Config {
checkClusterServersConfig();
checkSingleServerConfig();
checkSentinelServersConfig();
checkElasticacheReplicationGroupServersConfig();
checkElasticacheServersConfig();
if (masterSlaveServersConfig == null) {
masterSlaveServersConfig = new MasterSlaveServersConfig();
@ -224,8 +224,8 @@ public class Config {
}
}
private void checkElasticacheReplicationGroupServersConfig() {
if (elasticacheReplicationGroupServersConfig != null) {
private void checkElasticacheServersConfig() {
if (elasticacheServersConfig != null) {
throw new IllegalStateException("elasticache replication group servers config already used!");
}
}

10
src/main/java/org/redisson/ElasticacheReplicationGroupServersConfig.java → src/main/java/org/redisson/ElasticacheServersConfig.java
Unescape Escape View File

@ -27,7 +27,7 @@ import org.redisson.misc.URIBuilder;
*
* @author Steve Ungerer
*/
public class ElasticacheReplicationGroupServersConfig extends BaseMasterSlaveServersConfig<ElasticacheReplicationGroupServersConfig> {
public class ElasticacheServersConfig extends BaseMasterSlaveServersConfig<ElasticacheServersConfig> {
/**
* Replication group node urls list
@ -39,10 +39,10 @@ public class ElasticacheReplicationGroupServersConfig extends BaseMasterSlaveSer
*/
private int scanInterval = 1000;
public ElasticacheReplicationGroupServersConfig() {
public ElasticacheServersConfig() {
}
ElasticacheReplicationGroupServersConfig(ElasticacheReplicationGroupServersConfig config) {
ElasticacheServersConfig(ElasticacheServersConfig config) {
super(config);
setNodeAddresses(config.getNodeAddresses());
setScanInterval(config.getScanInterval());
@ -54,7 +54,7 @@ public class ElasticacheReplicationGroupServersConfig extends BaseMasterSlaveSer
* @param addresses in <code>host:port</code> format
* @return
*/
public ElasticacheReplicationGroupServersConfig addNodeAddress(String ... addresses) {
public ElasticacheServersConfig addNodeAddress(String ... addresses) {
for (String address : addresses) {
nodeAddresses.add(URIBuilder.create(address));
}
@ -76,7 +76,7 @@ public class ElasticacheReplicationGroupServersConfig extends BaseMasterSlaveSer
* @param scanInterval in milliseconds
* @return
*/
public ElasticacheReplicationGroupServersConfig setScanInterval(int scanInterval) {
public ElasticacheServersConfig setScanInterval(int scanInterval) {
this.scanInterval = scanInterval;
return this;
}

6
src/main/java/org/redisson/Redisson.java
Unescape Escape View File

@ -25,7 +25,7 @@ import java.util.concurrent.atomic.AtomicLong;
import org.redisson.client.protocol.RedisCommands;
import org.redisson.connection.ClusterConnectionManager;
import org.redisson.connection.ConnectionManager;
import org.redisson.connection.ElasticacheReplicationGroupConnectionManager;
import org.redisson.connection.ElasticacheConnectionManager;
import org.redisson.connection.MasterSlaveConnectionManager;
import org.redisson.connection.SentinelConnectionManager;
import org.redisson.connection.SingleConnectionManager;
@ -79,8 +79,8 @@ public class Redisson implements RedissonClient {
connectionManager = new SentinelConnectionManager(configCopy.getSentinelServersConfig(), configCopy);
} else if (configCopy.getClusterServersConfig() != null) {
connectionManager = new ClusterConnectionManager(configCopy.getClusterServersConfig(), configCopy);
} else if (configCopy.getElasticacheReplicationGroupServersConfig() != null) {
connectionManager = new ElasticacheReplicationGroupConnectionManager(configCopy.getElasticacheReplicationGroupServersConfig(), configCopy);
} else if (configCopy.getElasticacheServersConfig() != null) {
connectionManager = new ElasticacheConnectionManager(configCopy.getElasticacheServersConfig(), configCopy);
} else {
throw new IllegalArgumentException("server(s) address(es) not defined!");
}

12
src/main/java/org/redisson/connection/ElasticacheReplicationGroupConnectionManager.java → src/main/java/org/redisson/connection/ElasticacheConnectionManager.java
Unescape Escape View File

@ -22,7 +22,7 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import org.redisson.Config;
import org.redisson.ElasticacheReplicationGroupServersConfig;
import org.redisson.ElasticacheServersConfig;
import org.redisson.MasterSlaveServersConfig;
import org.redisson.client.RedisClient;
import org.redisson.client.RedisConnection;
@ -42,7 +42,7 @@ import io.netty.util.concurrent.ScheduledFuture;
*
* @author Steve Ungerer
*/
public class ElasticacheReplicationGroupConnectionManager extends MasterSlaveConnectionManager {
public class ElasticacheConnectionManager extends MasterSlaveConnectionManager {
private static final String ROLE_KEY = "role:";
@ -59,7 +59,7 @@ public class ElasticacheReplicationGroupConnectionManager extends MasterSlaveCon
slave
}
public ElasticacheReplicationGroupConnectionManager(ElasticacheReplicationGroupServersConfig cfg, Config config) {
public ElasticacheConnectionManager(ElasticacheServersConfig cfg, Config config) {
init(config);
this.config = create(cfg);
@ -88,7 +88,7 @@ public class ElasticacheReplicationGroupConnectionManager extends MasterSlaveCon
monitorRoleChange(cfg);
}
private RedisConnection connect(ElasticacheReplicationGroupServersConfig cfg, URI addr) {
private RedisConnection connect(ElasticacheServersConfig cfg, URI addr) {
RedisConnection connection = nodeConnections.get(addr);
if (connection != null) {
return connection;
@ -105,7 +105,7 @@ public class ElasticacheReplicationGroupConnectionManager extends MasterSlaveCon
return connection;
}
private void monitorRoleChange(final ElasticacheReplicationGroupServersConfig cfg) {
private void monitorRoleChange(final ElasticacheServersConfig cfg) {
monitorFuture = GlobalEventExecutor.INSTANCE.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
@ -145,7 +145,7 @@ public class ElasticacheReplicationGroupConnectionManager extends MasterSlaveCon
throw new RedisException("Cannot determine node role from provided 'INFO replication' data");
}
private MasterSlaveServersConfig create(ElasticacheReplicationGroupServersConfig cfg) {
private MasterSlaveServersConfig create(ElasticacheServersConfig cfg) {
MasterSlaveServersConfig c = new MasterSlaveServersConfig();
c.setRetryInterval(cfg.getRetryInterval());
c.setRetryAttempts(cfg.getRetryAttempts());
Write Preview
Loading…
Cancel
Save