svn commit: r731821 - /servicemix/components/shared-libraries/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java

[ff...@apache.org]

Author: ffang
Date: Mon Jan  5 19:33:34 2009
New Revision: 731821

URL: http://svn.apache.org/viewvc?rev=731821&view=rev
Log:
[SM-1755]add addtional log for SimpleEndpoint

Modified:
    servicemix/components/shared-libraries/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java

Modified: servicemix/components/shared-libraries/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/components/shared-libraries/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java?rev=731821&r1=731820&r2=731821&view=diff
==============================================================================
--- servicemix/components/shared-libraries/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java (original)
+++ servicemix/components/shared-libraries/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java Mon Jan  5 19:33:34 2009
@@ -29,9 +29,13 @@
 import org.apache.servicemix.common.Endpoint;
 import org.apache.servicemix.common.EndpointComponentContext;
 import org.apache.servicemix.common.ServiceUnit;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 
 public abstract class SimpleEndpoint extends AbstractEndpoint {
 
+    private static final Log LOG = LogFactory.getLog(SimpleEndpoint.class);
+
     private DeliveryChannel channel;
     private MessageExchangeFactory exchangeFactory;
     private ComponentContext context;
@@ -73,11 +77,19 @@
     }
     
     protected void done(MessageExchange me) throws MessagingException {
+        if (LOG.isDebugEnabled()) {
+            LOG.debug("SimpleEndpoint.done called: ");
+        }
+
         me.setStatus(ExchangeStatus.DONE);
         send(me);
     }
     
     protected void fail(MessageExchange me, Exception error) throws MessagingException {
+        if (LOG.isWarnEnabled()) {
+            LOG.warn("SimpleEndpoint.fail called: ");
+        }
+
         me.setError(error);
         send(me);
     }