svn commit: r1066015 - /tuscany/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java

[an...@apache.org]

Author: antelder
Date: Tue Feb  1 11:56:55 2011
New Revision: 1066015

URL: http://svn.apache.org/viewvc?rev=1066015&view=rev
Log:
Start quiet logging updates by changing endpoint registry logging. Seems a little long winded so maybe need to find somethinf simpler

Modified:
    tuscany/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java

Modified: tuscany/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java?rev=1066015&r1=1066014&r2=1066015&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/EndpointRegistryImpl.java Tue Feb  1 11:56:55 2011
@@ -22,14 +22,19 @@ package org.apache.tuscany.sca.core.asse
 import java.util.ArrayList;
 import java.util.Iterator;
 import java.util.List;
+import java.util.Properties;
+import java.util.logging.Level;
 import java.util.logging.Logger;
 
+import org.apache.tuscany.sca.assembly.Binding;
 import org.apache.tuscany.sca.assembly.Endpoint;
 import org.apache.tuscany.sca.core.ExtensionPointRegistry;
 import org.apache.tuscany.sca.core.LifeCycleListener;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
 import org.apache.tuscany.sca.runtime.BaseEndpointRegistry;
 import org.apache.tuscany.sca.runtime.EndpointListener;
 import org.apache.tuscany.sca.runtime.EndpointRegistry;
+import org.apache.tuscany.sca.runtime.RuntimeProperties;
 
 /**
  * A EndpointRegistry implementation that sees registrations from the same JVM
@@ -38,9 +43,13 @@ public class EndpointRegistryImpl extend
     private final Logger logger = Logger.getLogger(EndpointRegistryImpl.class.getName());
 
     private List<Endpoint> endpoints = new ArrayList<Endpoint>();
+    
+    protected boolean quietLogging;
 
     public EndpointRegistryImpl(ExtensionPointRegistry extensionPoints, String endpointRegistryURI, String domainURI) {
         super(extensionPoints, null, endpointRegistryURI, domainURI);
+        Properties runtimeProps = extensionPoints.getExtensionPoint(UtilityExtensionPoint.class).getUtility(RuntimeProperties.class).getProperties();
+        quietLogging = Boolean.parseBoolean(runtimeProps.getProperty(RuntimeProperties.QUIET_LOGGING));
     }
 
     public synchronized void addEndpoint(Endpoint endpoint) {
@@ -48,7 +57,22 @@ public class EndpointRegistryImpl extend
         for (EndpointListener listener : listeners) {
             listener.endpointAdded(endpoint);
         }
-        logger.info("Add endpoint - " + endpoint.toString());
+        if (logger.isLoggable(quietLogging ? Level.FINE : Level.INFO)) {
+            String uri = null;
+            Binding b = endpoint.getBinding();
+            if (b != null) {
+                uri = b.getURI();
+                if (uri != null && uri.startsWith("/")) {
+                    uri = uri.substring(1);
+                }
+            }
+            String msg = "Add endpoint - " + (uri == null ? endpoint.getURI() : b.getType().getLocalPart()+" - " + uri);
+            if (quietLogging) {
+                logger.fine(msg);
+            } else {
+                logger.info(msg);
+            }
+        }
     }
 
     public List<Endpoint> findEndpoint(String uri) {
@@ -66,7 +90,22 @@ public class EndpointRegistryImpl extend
     public synchronized void removeEndpoint(Endpoint endpoint) {
         endpoints.remove(endpoint);
         endpointRemoved(endpoint);
-        logger.info("Remove endpoint - " + endpoint.toString());
+        if (logger.isLoggable(quietLogging ? Level.FINE : Level.INFO)) {
+            String uri = null;
+            Binding b = endpoint.getBinding();
+            if (b != null) {
+                uri = b.getURI();
+                if (uri != null && uri.startsWith("/")) {
+                    uri = uri.substring(1);
+                }
+            }
+            String msg = "Remove endpoint - " + (uri == null ? endpoint.getURI() : b.getType().getLocalPart()+" - "+uri);
+            if (quietLogging) {
+                logger.fine(msg);
+            } else {
+                logger.info(msg);
+            }
+        }
     }
 
     public synchronized List<Endpoint> getEndpoints() {