Makes RedisObelixStore prefix customizable

inveniosoftware-contrib · May 22, 2015 · 1f5f29d · 1f5f29d
1 parent 965193a
commit 1f5f29d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/src/main/java/Main.java b/src/main/java/Main.java
@@ -167,7 +167,7 @@ public static void main(String... args) {
 
         (new Thread(new ObelixWebServer(graphDb, webPort, recommendationDepth, clientSettings()))).start();
 
-        (new Thread(new ObelixCache(graphDb, usersCacheQueue, new RedisObelixStore(),
+        (new Thread(new ObelixCache(graphDb, usersCacheQueue, new RedisObelixStore(redisQueuePrefix),
                 buildForAllUsersOnStartup, recommendationDepth, maxRelationships,
                 clientSettings()))).start();
 

diff --git a/src/main/java/obelix/ObelixFeeder.java b/src/main/java/obelix/ObelixFeeder.java
@@ -33,7 +33,6 @@ public ObelixFeeder(GraphDatabaseService graphDb, int maxRelationships,
         this.maxRelationships = maxRelationships;
         this.graphDb = graphDb;
         this.workerID = workerID;
-
     }
 
     public void run() {

diff --git a/src/main/java/store/impl/RedisObelixStore.java b/src/main/java/store/impl/RedisObelixStore.java
@@ -15,6 +15,11 @@ public RedisObelixStore() {
         this.redisPool = new RedisPool();
     }
 
+    public RedisObelixStore(String prefix) {
+        this.prefix = prefix;
+        this.redisPool = new RedisPool();
+    }
+
     @Override
     public void set(String key, ObelixStoreElement value)
     {