You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by sh...@apache.org on 2017/01/24 10:03:47 UTC
incubator-unomi git commit: UNOMI-70 - Improve cluster timeout
messages
Repository: incubator-unomi
Updated Branches:
refs/heads/master 8b1c30a22 -> 92542e5b1
UNOMI-70
- Improve cluster timeout messages
Signed-off-by: Serge Huber <sh...@apache.org>
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 <sh...@apache.org>
Authored: Tue Jan 24 11:03:40 2017 +0100
Committer: Serge Huber <sh...@apache.org>
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