Class CometdConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultConsumer
-
- org.apache.camel.component.cometd.CometdConsumer
-
- All Implemented Interfaces:
AutoCloseable
,CometdProducerConsumer
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.RouteAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class CometdConsumer extends org.apache.camel.support.DefaultConsumer implements CometdProducerConsumer
A Consumer for receiving messages using Cometd and Bayeux protocol.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CometdConsumer.ConsumerService
-
Constructor Summary
Constructors Constructor Description CometdConsumer(CometdEndpoint endpoint, org.apache.camel.Processor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
doStart()
void
doStop()
CometdConsumer.ConsumerService
getConsumerService()
CometdEndpoint
getEndpoint()
Gets the endpointvoid
setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
Sets the bayeux to use.-
Methods inherited from class org.apache.camel.support.DefaultConsumer
createUoW, doInit, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, setExceptionHandler, setRoute, setRouteId, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
CometdConsumer
public CometdConsumer(CometdEndpoint endpoint, org.apache.camel.Processor processor)
-
-
Method Detail
-
doStart
public void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
doStop
public void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
setBayeux
public void setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
Description copied from interface:CometdProducerConsumer
Sets the bayeux to use.- Specified by:
setBayeux
in interfaceCometdProducerConsumer
-
getEndpoint
public CometdEndpoint getEndpoint()
Description copied from interface:CometdProducerConsumer
Gets the endpoint- Specified by:
getEndpoint
in interfaceCometdProducerConsumer
- Specified by:
getEndpoint
in interfaceorg.apache.camel.EndpointAware
- Overrides:
getEndpoint
in classorg.apache.camel.support.DefaultConsumer
-
getConsumerService
public CometdConsumer.ConsumerService getConsumerService()
-
-