org.apache.camel.impl
Class DefaultConsumer<E extends Exchange>
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.impl.DefaultConsumer<E>
- All Implemented Interfaces:
- Consumer<E>, Service
- Direct Known Subclasses:
- JMXConsumer, ScheduledPollConsumer, TimerConsumer
public class DefaultConsumer<E extends Exchange>
- extends ServiceSupport
- implements Consumer<E>
- Version:
- $Revision: 563607 $
DefaultConsumer
public DefaultConsumer(Endpoint<E> endpoint,
Processor processor)
toString
public String toString()
- Overrides:
toString
in class Object
getEndpoint
public Endpoint<E> getEndpoint()
getProcessor
public Processor getProcessor()
getExceptionHandler
public ExceptionHandler getExceptionHandler()
setExceptionHandler
public void setExceptionHandler(ExceptionHandler exceptionHandler)
doStop
protected void doStop()
throws Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
Exception
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class ServiceSupport
- Throws:
Exception
handleException
protected void handleException(Throwable t)
- Handles the given exception using the
getExceptionHandler()
- Parameters:
t
- the exception to handle
Copyright © 2007 Apache Software Foundation. All Rights Reserved.