org.apache.activemq.camel.component.broker
Class BrokerConsumer

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.activemq.camel.component.broker.BrokerConsumer
All Implemented Interfaces:
MessageInterceptor, org.apache.camel.Consumer, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class BrokerConsumer
extends org.apache.camel.impl.DefaultConsumer
implements MessageInterceptor


Field Summary
protected  Logger logger
           
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
BrokerConsumer(org.apache.camel.Endpoint endpoint, org.apache.camel.Processor processor)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 void intercept(ProducerBrokerExchange producerExchange, Message message)
           
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Field Detail

logger

protected final transient Logger logger
Constructor Detail

BrokerConsumer

public BrokerConsumer(org.apache.camel.Endpoint endpoint,
                      org.apache.camel.Processor processor)
Method Detail

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.impl.DefaultConsumer
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class org.apache.camel.impl.DefaultConsumer
Throws:
Exception

intercept

public void intercept(ProducerBrokerExchange producerExchange,
                      Message message)
Specified by:
intercept in interface MessageInterceptor


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.