代码修改

patient-co/patient-co-wlyy-job/src/main/java/com/yihu/wlyy/redis/RedisThread.java

@@ -36,6 +36,7 @@ public class RedisThread implements Runnable {
    private PushMsgTask pushMsgTask;
    //redis链接池
    private JedisPool pool;
    private Jedis jedis;
    @Override
    public void run() {
@@ -45,7 +46,6 @@ public class RedisThread implements Runnable {
        while (true){
            try {
                Jedis jedis = pool.getResource();
                String message = jedis.rpop(key);
                if(StringUtils.isEmpty(message)){
                    sleep(1000L);//如果没有读取到记录,等待1秒
@@ -80,6 +80,7 @@ public class RedisThread implements Runnable {
        }else {
            pool = new JedisPool(poolConfig,host,port,100000);
        }
        jedis = pool.getResource();
    }
    public void redisMessage(String message){