commit 2a564a9b1d32070a2db3f1404137dac3a13a833c
author Christian Schneider <cschneid@adobe.com> Fri Sep 28 09:39:36 2018 +0200
committer Christian Schneider <cschneid@adobe.com> Fri Sep 28 09:39:36 2018 +0200
tree 5fb47329a627267d19fabbdb14b2d6cf95ab2c0d
parent 17c32cb0c9c58c258c9efa5484d43504ab42cd83

Unify logging message

discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/publish/PublishingEndpointListener.java

diff --git a/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/publish/PublishingEndpointListener.java b/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/publish/PublishingEndpointListener.java
index ceef6b0..8f6f433 100644
--- a/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/publish/PublishingEndpointListener.java
+++ b/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/publish/PublishingEndpointListener.java
@@ -87,8 +87,8 @@
     private void endpointModified(EndpointDescription endpoint, String filter) {
         try {
             repository.modify(endpoint);
-        } catch (Exception e) {
-            LOG.error("Error modifying endpoint data in zookeeper for endpoint {}", endpoint.getId(), e);
+        } catch (Exception ex) {
+            logException("modification", endpoint, ex);
         }
     }
 
@@ -97,7 +97,7 @@
         try {
             repository.add(endpoint);
         } catch (Exception ex) {
-            LOG.error("Exception while processing the addition of an endpoint.", ex);
+            logException("adding", endpoint, ex);
         }
     }
 
@@ -106,8 +106,13 @@
         try {
             repository.remove(endpoint);
         } catch (Exception ex) {
-            LOG.error("Exception while processing the removal of an endpoint", ex);
+            logException("removal", endpoint, ex);
         }
     }
+    
+    private void logException(String operation, EndpointDescription endpoint, Exception ex) {
+        String msg = String.format("Exception during %s of endpoint %s", operation, endpoint.getId());
+        LOG.error(msg, ex);
+    }
 
 }