fix: fix bug that "Redis sub exception occurs and sync becomes invalid" (#30)

* Update SubThread.java

fix bug #29

* Update SubThread.java

Co-authored-by: Yang Luo <[email protected]>

Author: yu-hailong

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

@@ -26,10 +26,18 @@ public void setUpdateCallback(Consumer<String> consumer) {
 
     @Override
     public void run() {
-        try (Jedis jedis = jedisPool.getResource()) {
-            jedis.subscribe(subscriber, channel);
-        } catch (Exception e) {
-            e.printStackTrace();
+        while (true) {
+            try (Jedis jedis = jedisPool.getResource()) {
+                jedis.subscribe(subscriber, channel);
+            } catch (Exception e) {
+                e.printStackTrace();
+            } finally {
+                try {
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
         }
     }
 }