Class CometdProducer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultProducer
-
- org.apache.camel.component.cometd.CometdProducer
-
- All Implemented Interfaces:
AutoCloseable
,CometdProducerConsumer
,org.apache.camel.EndpointAware
,org.apache.camel.IsSingleton
,org.apache.camel.Processor
,org.apache.camel.Producer
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class CometdProducer extends org.apache.camel.support.DefaultProducer implements CometdProducerConsumer
A Producer to send messages using Cometd and Bayeux protocol.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CometdProducer.ProducerService
-
Constructor Summary
Constructors Constructor Description CometdProducer(CometdEndpoint endpoint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
doStart()
void
doStop()
org.cometd.server.BayeuxServerImpl
getBayeux()
CometdEndpoint
getEndpoint()
Gets the endpointprotected CometdProducer.ProducerService
getProducerService()
void
process(org.apache.camel.Exchange exchange)
void
setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
Sets the bayeux to use.-
Methods inherited from class org.apache.camel.support.DefaultProducer
createExchange, isSingleton, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, 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
-
CometdProducer
public CometdProducer(CometdEndpoint endpoint)
-
-
Method Detail
-
doStart
public void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultProducer
- Throws:
Exception
-
doStop
public void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultProducer
- Throws:
Exception
-
process
public void process(org.apache.camel.Exchange exchange)
- Specified by:
process
in interfaceorg.apache.camel.Processor
-
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.DefaultProducer
-
getBayeux
public org.cometd.server.BayeuxServerImpl getBayeux()
-
getProducerService
protected CometdProducer.ProducerService getProducerService()
-
setBayeux
public void setBayeux(org.cometd.server.BayeuxServerImpl bayeux)
Description copied from interface:CometdProducerConsumer
Sets the bayeux to use.- Specified by:
setBayeux
in interfaceCometdProducerConsumer
-
-