Repository: incubator-unomi Updated Branches: refs/heads/master 8b1c30a22 -> 92542e5b1
UNOMI-70 - Improve cluster timeout messages Signed-off-by: Serge Huber <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/92542e5b Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/92542e5b Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/92542e5b Branch: refs/heads/master Commit: 92542e5b11e8bf333a8bda3b102ecbc9baf6d0e2 Parents: 8b1c30a Author: Serge Huber <[email protected]> Authored: Tue Jan 24 11:03:40 2017 +0100 Committer: Serge Huber <[email protected]> Committed: Tue Jan 24 11:03:40 2017 +0100 ---------------------------------------------------------------------- .../org/apache/unomi/services/services/ClusterServiceImpl.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/92542e5b/services/src/main/java/org/apache/unomi/services/services/ClusterServiceImpl.java ---------------------------------------------------------------------- diff --git a/services/src/main/java/org/apache/unomi/services/services/ClusterServiceImpl.java b/services/src/main/java/org/apache/unomi/services/services/ClusterServiceImpl.java index 50de1b5..7c77e8d 100644 --- a/services/src/main/java/org/apache/unomi/services/services/ClusterServiceImpl.java +++ b/services/src/main/java/org/apache/unomi/services/services/ClusterServiceImpl.java @@ -313,7 +313,11 @@ public class ClusterServiceImpl implements ClusterService { } catch (IOException e1) { logger.error("Error closing invalid JMX connection", e1); } - logger.error("Error using the JMX connection to url {}, closed and will reconnect", url, e); + if (e.getMessage() != null && e.getMessage().contains("Connection closed")) { + logger.warn("JMX connection to url {} was closed (Cause:{}). Reconnecting...", url, e.getMessage()); + } else { + logger.error("Error using the JMX connection to url {}, closed and will reconnect", url, e); + } } } // if we reach this point either we didn't have a connector or it didn't validate
