svn commit: r731816 - /servicemix/smx3/branches/servicemix-3.2/common/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java

[ff...@apache.org]

Author: ffang
Date: Mon Jan  5 19:21:28 2009
New Revision: 731816

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

Modified:
    servicemix/smx3/branches/servicemix-3.2/common/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java

Modified: servicemix/smx3/branches/servicemix-3.2/common/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/common/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java?rev=731816&r1=731815&r2=731816&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/common/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/common/servicemix-common/src/main/java/org/apache/servicemix/common/endpoints/SimpleEndpoint.java Mon Jan  5 19:21:28 2009
@@ -30,8 +30,11 @@
 import org.apache.servicemix.common.EndpointComponentContext;
 import org.apache.servicemix.common.ExchangeProcessor;
 import org.apache.servicemix.common.ServiceUnit;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 
 public abstract class SimpleEndpoint extends Endpoint implements ExchangeProcessor {
+    private static final Log LOG = LogFactory.getLog(SimpleEndpoint.class);
 
     private DeliveryChannel channel;
     private MessageExchangeFactory exchangeFactory;
@@ -74,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);
     }