feat: add jedis pool config (#28)

Author: xuyukeviki

src/main/java/org/casbin/watcher/RedisWatcher.java

@@ -22,6 +22,13 @@ public RedisWatcher(String redisIp, int redisPort, String redisChannelName, int
         startSub();
     }
 
+    public RedisWatcher(JedisPoolConfig config, String redisIp, int redisPort, String redisChannelName, int timeout, String password) {
+        this.jedisPool = new JedisPool(config, redisIp, redisPort, timeout, password);
+        this.localId = UUID.randomUUID().toString();
+        this.redisChannelName = redisChannelName;
+        startSub();
+    }
+
     public RedisWatcher(String redisIp, int redisPort, String redisChannelName) {
         this(redisIp, redisPort, redisChannelName, 2000, (String)null);
     }

src/test/java/org/casbin/test/RedisWatcherTest.java

@@ -5,22 +5,42 @@
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
+import redis.clients.jedis.JedisPoolConfig;
+
 import java.io.ByteArrayOutputStream;
 import java.io.PrintStream;
 
 public class RedisWatcherTest {
-    private RedisWatcher redisWatcher;
+    private RedisWatcher redisWatcher,redisConfigWatcher;
     private final String expect="update msg";
+    private final String expectConfig="update msg for config";
 
     /**
      * You should replace the initWatcher() method's content with your own Redis instance.
      */
     @Before
     public void initWatcher(){
         String redisTopic = "jcasbin-topic";
+        String redisConfig = "jcasbin-config";
+        JedisPoolConfig config = new JedisPoolConfig();
+        config.setMaxTotal(2);
+        config.setMaxWaitMillis(100 * 1000);
         redisWatcher = new RedisWatcher("127.0.0.1",6379, redisTopic, 2000, "foobared");
+        redisConfigWatcher = new RedisWatcher(config,"127.0.0.1",6376, redisConfig, 2000, "foobaredConfig");
         Enforcer enforcer = new Enforcer();
         enforcer.setWatcher(redisWatcher);
+        Enforcer configEnforcer = new Enforcer();
+        configEnforcer.setWatcher(redisConfigWatcher);
+    }
+
+    @Test
+    public void testConfigUpdate() throws InterruptedException {
+        ByteArrayOutputStream baos = new ByteArrayOutputStream();
+        System.setOut(new PrintStream(baos));
+        redisConfigWatcher.setUpdateCallback(()-> System.out.print(expectConfig) );
+        redisConfigWatcher.update();
+        Thread.sleep(100);
+        Assert.assertEquals(expectConfig, expectConfig);
     }
 
     @Test
@@ -40,12 +60,22 @@ public void testConsumerCallback() throws InterruptedException {
         });
         redisWatcher.update();
         Thread.sleep(100);
+
+        redisConfigWatcher.setUpdateCallback((s) -> {
+            System.out.print(s);
+        });
+        redisConfigWatcher.update();
+        Thread.sleep(100);
     }
 
     @Test
     public void testConnectWatcherWithoutPassword() {
         String redisTopic = "jcasbin-topic";
         RedisWatcher redisWatcherWithoutPassword = new RedisWatcher("127.0.0.1", 6378, redisTopic);
         Assert.assertNotNull(redisWatcherWithoutPassword);
+
+        String redisConfig = "jcasbin-config";
+        RedisWatcher redisConfigWatcherWithoutPassword = new RedisWatcher("127.0.0.1", 6377, redisConfig);
+        Assert.assertNotNull(redisConfigWatcherWithoutPassword);
     }
 }