Skip to content

Commit

Permalink
removed some redis stuff
Browse files Browse the repository at this point in the history
dsgipe committed Jul 17, 2018
1 parent e84b344 commit 69612b6
Showing 1 changed file with 5 additions and 23 deletions.
Original file line number Diff line number Diff line change
@@ -1,38 +1,21 @@
package io.pivotal.pal.tracker.allocations;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.slf4j.LoggerFactory;
import org.slf4j.Logger;
import org.springframework.web.client.RestOperations;

import java.util.concurrent.ConcurrentMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class ProjectClient {
private Logger logger;
private final Map<Long, ProjectInfo> projectsCache = new ConcurrentHashMap<>();

private final RestOperations restOperations;
private final String registrationServerEndpoint;

private ConcurrentMap<Long, ProjectInfo> map;

private RedissonClient redisson;
private void ConfigureRedis(){
//GetRunningEnvironmentVariablesRequest.build();
String host = "10.0.8.3";
int port = 43191;
Config config = new Config();
config.useSingleServer().setAddress("redis://"+host +":" + port);
redisson = Redisson.create();
map=redisson.getMap("someMap");
}

public ProjectClient(RestOperations restOperations, String registrationServerEndpoint) {

ConfigureRedis();

logger = LoggerFactory.getLogger(getClass());
this.restOperations= restOperations;
this.registrationServerEndpoint = registrationServerEndpoint;
@@ -42,14 +25,13 @@ public ProjectClient(RestOperations restOperations, String registrationServerEnd
public ProjectInfo getProject(long projectId) {
ProjectInfo projectInfo = restOperations.getForObject
(registrationServerEndpoint + "/projects/" + projectId, ProjectInfo.class);

map.put(projectId,projectInfo);
projectsCache.put(projectId,projectInfo);
return projectInfo;
}

public ProjectInfo getProjectFromCache(long projectId) {
logger.info("Getting project with id {} from cache", projectId);
return map.get(projectId);
return projectsCache.get(projectId);
}

}

0 comments on commit 69612b6

Please sign in to comment.