Class DirectEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.direct.DirectEndpoint
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Endpoint
,org.apache.camel.IsSingleton
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.HasId
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@UriEndpoint(firstVersion="1.0.0", scheme="direct", title="Direct", syntax="direct:name", category={CORE,ENDPOINT}) public class DirectEndpoint extends org.apache.camel.support.DefaultEndpoint
Call another endpoint from the same Camel Context synchronously. This endpoint can be used to connect existing routes in the same CamelContext.
-
-
Constructor Summary
Constructors Constructor Description DirectEndpoint(String uri, DirectComponent component)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer
createProducer()
DirectConsumer
getConsumer()
Deprecated.long
getTimeout()
boolean
isBlock()
boolean
isFailIfNoConsumers()
boolean
isSynchronous()
void
setBlock(boolean block)
If sending a message to a direct endpoint which has no active consumer, then we can tell the producer to block and wait for the consumer to become active.void
setFailIfNoConsumers(boolean failIfNoConsumers)
Whether the producer should fail by throwing an exception, when sending to a DIRECT endpoint with no active consumers.void
setSynchronous(boolean synchronous)
Whether synchronous processing is forced.void
setTimeout(long timeout)
The timeout value to use if block is enabled.-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configureExchange, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isPollingConsumerCopy, isSingleton, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerCopy, setPollingConsumerQueueSize, setProperties, 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, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
DirectEndpoint
public DirectEndpoint(String uri, DirectComponent component)
-
-
Method Detail
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Throws:
Exception
-
getConsumer
@Deprecated public DirectConsumer getConsumer() throws InterruptedException
Deprecated.- Throws:
InterruptedException
-
isSynchronous
public boolean isSynchronous()
-
setSynchronous
public void setSynchronous(boolean synchronous)
Whether synchronous processing is forced. If enabled then the producer thread, will be forced to wait until the message has been completed before the same thread will continue processing. If disabled (default) then the producer thread may be freed and can do other work while the message is continued processed by other threads (reactive).
-
isBlock
public boolean isBlock()
-
setBlock
public void setBlock(boolean block)
If sending a message to a direct endpoint which has no active consumer, then we can tell the producer to block and wait for the consumer to become active.
-
getTimeout
public long getTimeout()
-
setTimeout
public void setTimeout(long timeout)
The timeout value to use if block is enabled.
-
isFailIfNoConsumers
public boolean isFailIfNoConsumers()
-
setFailIfNoConsumers
public void setFailIfNoConsumers(boolean failIfNoConsumers)
Whether the producer should fail by throwing an exception, when sending to a DIRECT endpoint with no active consumers.
-
-