|
@ -147,7 +147,9 @@ public class RedisPubSubStore implements PubSubStore { |
|
|
try { |
|
|
try { |
|
|
sub.subscribe(jedisPubSub, name); |
|
|
sub.subscribe(jedisPubSub, name); |
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
log.error("error", e); |
|
|
|
|
|
|
|
|
if (!executorService.isShutdown()) { |
|
|
|
|
|
log.error(e.getMessage(), e); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
}); |
|
|
}); |
|
|