public class CometdProducer extends org.apache.camel.impl.DefaultProducer implements CometdProducerConsumer
Modifier and Type | Class and Description |
---|---|
static class |
CometdProducer.ProducerService |
Constructor and Description |
---|
CometdProducer(CometdEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
org.cometd.server.BayeuxServerImpl |
getBayeux() |
CometdEndpoint |
getEndpoint()
Gets the endpoint
|
protected CometdProducer.ProducerService |
getProducerService() |
void |
process(org.apache.camel.Exchange exchange) |
void |
setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
Sets the bayeux to use.
|
void |
start() |
void |
stop() |
createExchange, createExchange, createExchange, doStart, doStop, isSingleton, toString
public CometdProducer(CometdEndpoint endpoint)
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 process(org.apache.camel.Exchange exchange)
process
in interface org.apache.camel.Processor
public CometdEndpoint getEndpoint()
CometdProducerConsumer
getEndpoint
in interface CometdProducerConsumer
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
public org.cometd.server.BayeuxServerImpl getBayeux()
protected CometdProducer.ProducerService getProducerService()
public void setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
CometdProducerConsumer
setBayeux
in interface CometdProducerConsumer
Apache Camel