diff --git a/src/main/java/com/corundumstudio/socketio/store/RedisPubSubStore.java b/src/main/java/com/corundumstudio/socketio/store/RedisPubSubStore.java index 91af746..998b686 100644 --- a/src/main/java/com/corundumstudio/socketio/store/RedisPubSubStore.java +++ b/src/main/java/com/corundumstudio/socketio/store/RedisPubSubStore.java @@ -147,7 +147,9 @@ public class RedisPubSubStore implements PubSubStore { try { sub.subscribe(jedisPubSub, name); } catch (Exception e) { - log.error("error", e); + if (!executorService.isShutdown()) { + log.error(e.getMessage(), e); + } } } });