Class ControlBusProducer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultProducer
-
- org.apache.camel.support.DefaultAsyncProducer
-
- org.apache.camel.component.controlbus.ControlBusProducer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.AsyncProcessor
,org.apache.camel.AsyncProducer
,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 ControlBusProducer extends org.apache.camel.support.DefaultAsyncProducer
The control bus producer.
-
-
Constructor Summary
Constructors Constructor Description ControlBusProducer(org.apache.camel.Endpoint endpoint, org.apache.camel.spi.CamelLogger logger)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ControlBusEndpoint
getEndpoint()
boolean
process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
protected void
processByAction(org.apache.camel.Exchange exchange)
protected void
processByLanguage(org.apache.camel.Exchange exchange, org.apache.camel.spi.Language language)
-
Methods inherited from class org.apache.camel.support.DefaultProducer
createExchange, doStart, doStop, 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
-
-
-
-
Method Detail
-
getEndpoint
public ControlBusEndpoint getEndpoint()
- Specified by:
getEndpoint
in interfaceorg.apache.camel.EndpointAware
- Overrides:
getEndpoint
in classorg.apache.camel.support.DefaultProducer
-
process
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
-
processByLanguage
protected void processByLanguage(org.apache.camel.Exchange exchange, org.apache.camel.spi.Language language)
-
processByAction
protected void processByAction(org.apache.camel.Exchange exchange)
-
-