passing the configuration when initialising the object instead of in the connection method
parent
df5aef1f55
commit
3a051f96fd
|
@ -11,11 +11,11 @@ public class KraCore {
|
|||
private final RedisManager redisManager;
|
||||
|
||||
public KraCore(MongoConfig mongoConfig, RedisConfig redisConfig) {
|
||||
this.mongoManager = new MongoManager();
|
||||
this.mongoManager.connect(mongoConfig);
|
||||
this.mongoManager = new MongoManager(mongoConfig);
|
||||
this.mongoManager.connect();
|
||||
|
||||
this.redisManager = new RedisManager();
|
||||
this.redisManager.connect(redisConfig);
|
||||
this.redisManager = new RedisManager(redisConfig);
|
||||
this.redisManager.connect();
|
||||
}
|
||||
|
||||
public void shutdown() {
|
||||
|
|
|
@ -7,9 +7,7 @@ import com.mongodb.ServerApiVersion;
|
|||
import com.mongodb.reactivestreams.client.MongoClient;
|
||||
import com.mongodb.reactivestreams.client.MongoClients;
|
||||
import earth.krakatoa.core.config.MongoConfig;
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class MongoManager {
|
||||
|
||||
private ConnectionString connectionString;
|
||||
|
@ -18,7 +16,13 @@ public class MongoManager {
|
|||
private MongoClientSettings mongoClientSettings;
|
||||
private MongoClient mongoClient;
|
||||
|
||||
public void connect(MongoConfig mongoConfig) {
|
||||
private MongoConfig mongoConfig;
|
||||
|
||||
public MongoManager(MongoConfig mongoConfig) {
|
||||
this.mongoConfig = mongoConfig;
|
||||
}
|
||||
|
||||
public void connect() {
|
||||
this.connectionString = new ConnectionString(
|
||||
"mongodb://" + mongoConfig.getUsername() + ":" + mongoConfig.getPassword() + "@"
|
||||
+ mongoConfig.getHostname() + ":" + mongoConfig.getPort() + "/?authSource="
|
||||
|
|
|
@ -1,20 +1,24 @@
|
|||
package earth.krakatoa.core.redis;
|
||||
|
||||
import earth.krakatoa.core.config.RedisConfig;
|
||||
import lombok.Data;
|
||||
import org.redisson.Redisson;
|
||||
import org.redisson.api.RedissonClient;
|
||||
import org.redisson.config.Config;
|
||||
|
||||
@Data
|
||||
public class RedisManager {
|
||||
|
||||
private Config config;
|
||||
private RedissonClient redissonClient;
|
||||
|
||||
public void connect(RedisConfig redisConfig) {
|
||||
private RedisConfig redisConfig;
|
||||
|
||||
public RedisManager(RedisConfig redisConfig) {
|
||||
this.redisConfig = redisConfig;
|
||||
}
|
||||
|
||||
public void connect() {
|
||||
this.config = new Config();
|
||||
this.config.useSingleServer().setAddress("redis://" + redisConfig.getIp() + ":" + redisConfig.getPort());
|
||||
this.config.useSingleServer().setAddress("redis://" + this.redisConfig.getIp() + ":" + this.redisConfig.getPort());
|
||||
|
||||
this.redissonClient = Redisson.create(this.config);
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue