public class CometdConsumer extends org.apache.camel.impl.DefaultConsumer implements CometdProducerConsumer
Modifier and Type | Class and Description |
---|---|
static class |
CometdConsumer.ConsumerService |
Constructor and Description |
---|
CometdConsumer(CometdEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
CometdConsumer.ConsumerService |
getConsumerService() |
CometdEndpoint |
getEndpoint()
Gets the endpoint
|
void |
setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
Sets the bayeux to use.
|
void |
start() |
void |
stop() |
createUoW, doneUoW, doStart, doStop, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
public CometdConsumer(CometdEndpoint endpoint, org.apache.camel.Processor processor)
public void start() throws Exception
start
in interface org.apache.camel.Service
start
in class org.apache.camel.support.ServiceSupport
Exception
public void stop() throws Exception
stop
in interface org.apache.camel.Service
stop
in class org.apache.camel.support.ServiceSupport
Exception
public void setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
CometdProducerConsumer
setBayeux
in interface CometdProducerConsumer
public CometdEndpoint getEndpoint()
CometdProducerConsumer
getEndpoint
in interface CometdProducerConsumer
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
public CometdConsumer.ConsumerService getConsumerService()
Apache Camel