@UriEndpoint(scheme="direct-vm",
title="Direct VM",
syntax="direct-vm:name",
consumerClass=DirectConsumer.class,
label="core,endpoint")
public class DirectVmEndpoint
extends DefaultEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
DirectVmEndpoint(String endpointUri,
DirectVmComponent component) |
| Modifier and Type | Method and Description |
|---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
DirectVmComponent |
getComponent()
Returns the component that created this endpoint.
|
DirectVmConsumer |
getConsumer() |
long |
getTimeout() |
boolean |
isBlock() |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
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 |
setTimeout(long timeout)
The timeout value to use if block is enabled.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic DirectVmEndpoint(String endpointUri, DirectVmComponent component)
public DirectVmComponent getComponent()
DefaultEndpointgetComponent in class DefaultEndpointpublic Producer createProducer() throws Exception
EndpointException - can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
Endpointprocessor - the given processorException - can be thrownpublic boolean isSingleton()
IsSingletonpublic DirectVmConsumer getConsumer()
public boolean isBlock()
public void setBlock(boolean block)
public long getTimeout()
public void setTimeout(long timeout)
Apache Camel