org.apache.camel.component.direct
Class DirectEndpoint<E extends Exchange>
java.lang.Object
org.apache.camel.impl.DefaultEndpoint<E>
org.apache.camel.component.direct.DirectEndpoint<E>
- All Implemented Interfaces:
- CamelContextAware, Endpoint<E>
public class DirectEndpoint<E extends Exchange>
- extends DefaultEndpoint<E>
Represents a direct endpoint that synchronously invokes the consumers of the
endpoint when a producer sends a message to it.
- Version:
- $Revision: 41278 $
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureProperties, convertTo, createExchange, createExchange, createExchange, createExecutorService, createPollingConsumer, equals, getCamelContext, getComponent, getEndpointUri, getExchangePattern, getExchangeType, getExecutorService, hashCode, setCamelContext, setExchangePattern, setExecutorService, toString |
DirectEndpoint
public DirectEndpoint(String uri,
DirectComponent<E> component)
DirectEndpoint
public DirectEndpoint(String endpointUri)
createProducer
public Producer createProducer()
throws Exception
- Description copied from interface:
Endpoint
- Creates a new producer which is used send messages into the endpoint
- Returns:
- a newly created producer
- Throws:
Exception
createConsumer
public Consumer<E> createConsumer(Processor processor)
throws Exception
- Description copied from interface:
Endpoint
- Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
- Returns:
- a newly created consumer
- Throws:
Exception
isAllowMultipleConsumers
public boolean isAllowMultipleConsumers()
setAllowMultipleConsumers
public void setAllowMultipleConsumers(boolean allowMutlipleConsumers)
isSingleton
public boolean isSingleton()
- Description copied from interface:
Endpoint
- Returns if the endpoint should be a CamelContext singleton. If the
endpoint is a Singleton, then a single Endpoint instance will be shared
by all routes with the same URI. Because the endpoint is shared, it
should be treated as an immutable.
getConsumers
public List<DefaultConsumer<E>> getConsumers()
Copyright © 2008 IONA Open Source Community. All Rights Reserved.