svn commit: r936167 - /camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java

[da...@apache.org]

Author: davsclaus
Date: Wed Apr 21 06:16:42 2010
New Revision: 936167

URL: http://svn.apache.org/viewvc?rev=936167&view=rev
Log:
Fixed typo in method name

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java?rev=936167&r1=936166&r2=936167&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java Wed Apr 21 06:16:42 2010
@@ -24,8 +24,8 @@ import org.apache.camel.Consumer;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
-import org.apache.camel.processor.Logger;
 import org.apache.camel.spi.ExceptionHandler;
+import org.apache.camel.util.ServiceHelper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -38,8 +38,8 @@ import org.apache.commons.logging.LogFac
  */
 public class EventDrivenPollingConsumer extends PollingConsumerSupport implements Processor {
     private static final transient Log LOG = LogFactory.getLog(EventDrivenPollingConsumer.class);
-    private BlockingQueue<Exchange> queue;
-    private ExceptionHandler interuptedExceptionHandler = new LoggingExceptionHandler(new Logger(LOG));
+    private final BlockingQueue<Exchange> queue;
+    private ExceptionHandler interruptedExceptionHandler = new LoggingExceptionHandler(EventDrivenPollingConsumer.class);
     private Consumer consumer;
 
     public EventDrivenPollingConsumer(Endpoint endpoint) {
@@ -60,7 +60,7 @@ public class EventDrivenPollingConsumer 
             try {
                 return queue.take();
             } catch (InterruptedException e) {
-                handleInteruptedException(e);
+                handleInterruptedException(e);
             }
         }
         if (LOG.isTraceEnabled()) {
@@ -73,7 +73,7 @@ public class EventDrivenPollingConsumer 
         try {
             return queue.poll(timeout, TimeUnit.MILLISECONDS);
         } catch (InterruptedException e) {
-            handleInteruptedException(e);
+            handleInterruptedException(e);
             return null;
         }
     }
@@ -82,31 +82,25 @@ public class EventDrivenPollingConsumer 
         queue.offer(exchange);
     }
 
-    public ExceptionHandler getInteruptedExceptionHandler() {
-        return interuptedExceptionHandler;
+    public ExceptionHandler getInterruptedExceptionHandler() {
+        return interruptedExceptionHandler;
     }
 
-    public void setInteruptedExceptionHandler(ExceptionHandler interuptedExceptionHandler) {
-        this.interuptedExceptionHandler = interuptedExceptionHandler;
+    public void setInterruptedExceptionHandler(ExceptionHandler interruptedExceptionHandler) {
+        this.interruptedExceptionHandler = interruptedExceptionHandler;
     }
 
-    protected void handleInteruptedException(InterruptedException e) {
-        getInteruptedExceptionHandler().handleException(e);
+    protected void handleInterruptedException(InterruptedException e) {
+        getInterruptedExceptionHandler().handleException(e);
     }
 
     protected void doStart() throws Exception {
         // lets add ourselves as a consumer
         consumer = getEndpoint().createConsumer(this);
-        consumer.start();
+        ServiceHelper.startService(consumer);
     }
 
     protected void doStop() throws Exception {
-        if (consumer != null) {
-            try {
-                consumer.stop();
-            } finally {
-                consumer = null;
-            }
-        }
+        ServiceHelper.stopService(consumer);
     }
 }