Uses of Interface
org.apache.camel.Endpoint

Packages that use Endpoint

Package	Description
org.apache.camel	The core Camel API.
org.apache.camel.spi

Uses of Endpoint in org.apache.camel

Subinterfaces of Endpoint in org.apache.camel

Modifier and Type	Interface	Description
interface	ApiEndpoint	Marker interface indicating that an Endpoint belongs to an API-based component, where the endpoint URI encodes an API name and method name rather than a plain scheme and path.
interface	AsyncEndpoint	Marker interface indicating that the Endpoint's consumer and producer support asynchronous, non-blocking routing.
interface	DelegateEndpoint	An Endpoint that delegates all operations to another underlying Endpoint, following the Decorator pattern.

Methods in org.apache.camel with type parameters of type Endpoint

Modifier and Type	Method	Description
<T extends Endpoint> T	CamelContext.getEndpoint(String name, Class<T> endpointType)	Resolves the given name to an Endpoint of the specified type.
<T extends Endpoint> T	EndpointConsumerResolver.resolve(CamelContext context, Class<T> endpointType)	Resolves this object as an endpoint.
<T extends Endpoint> T	EndpointProducerResolver.resolve(CamelContext context, Class<T> endpointType)	Resolves this object as an endpoint.

Methods in org.apache.camel that return Endpoint

Modifier and Type	Method	Description
@Nullable Endpoint	CamelContext.addEndpoint(String uri, Endpoint endpoint)	Adds and starts the endpoint to the EndpointRegistry using the given URI.
@Nullable Endpoint	Component.createEndpoint(String uri)	Attempt to resolve an endpoint for the given URI if the component is capable of handling the URI.
@Nullable Endpoint	Component.createEndpoint(String uri, Map<String,Object> parameters)	Attempt to resolve an endpoint for the given URI if the component is capable of handling the URI.
@Nullable Endpoint	FluentProducerTemplate.getDefaultEndpoint()	Get the default endpoint to use if none is specified
@Nullable Endpoint	ProducerTemplate.getDefaultEndpoint()	Get the default endpoint to use if none is specified
Endpoint	CamelContext.getEndpoint(String uri)	Resolves the given name to an Endpoint of the specified type.
Endpoint	CamelContext.getEndpoint(String uri, Map<String,Object> parameters)	Resolves the given name to an Endpoint of the specified type.
Endpoint	DelegateEndpoint.getEndpoint()	Gets the delegated Endpoint.
Endpoint	EndpointAware.getEndpoint()	Gets the endpoint associated with an object.
Endpoint	ExtendedCamelContext.getEndpoint(NormalizedEndpointUri uri)	Resolves the given name to an Endpoint of the specified type.
Endpoint	ExtendedCamelContext.getEndpoint(NormalizedEndpointUri uri, Map<String,Object> parameters)	Resolves the given name to an Endpoint of the specified type.
Endpoint	ProxyInstantiationException.getEndpoint()
Endpoint	Route.getEndpoint()	Gets the input endpoint for this route.
@Nullable Endpoint	Exchange.getFromEndpoint()	Returns the endpoint which originated this message exchange if a consumer on an endpoint created the message exchange, otherwise this property will be null.
@Nullable Endpoint	ExchangeExtension.getFromEndpoint()	Returns the endpoint which originated this message exchange.
Endpoint	ExtendedCamelContext.getPrototypeEndpoint(String uri)	Resolves the given name to an Endpoint of the specified type (scope is prototype).
Endpoint	ExtendedCamelContext.getPrototypeEndpoint(NormalizedEndpointUri uri)	Resolves the given name to an Endpoint of the specified type (scope is prototype).
@Nullable Endpoint	CamelContext.hasEndpoint(String uri)	Is the given endpoint already registered in the EndpointRegistry
@Nullable Endpoint	ExtendedCamelContext.hasEndpoint(NormalizedEndpointUri uri)	Is the given endpoint already registered in the EndpointRegistry
Endpoint	EndpointConsumerResolver.resolve(CamelContext context)	Resolves this object as an endpoint.
Endpoint	EndpointProducerResolver.resolve(CamelContext context)	Resolves this object as an endpoint.

Methods in org.apache.camel that return types with arguments of type Endpoint

Modifier and Type	Method	Description
Collection<Endpoint>	CamelContext.getEndpoints()	Returns a read-only Collection of all of the endpoints from the EndpointRegistry
Collection<Endpoint>	CamelContext.removeEndpoints(String pattern)	Removes all endpoints with the given URI from the EndpointRegistry.

Methods in org.apache.camel with parameters of type Endpoint

Modifier and Type	Method	Description
@Nullable Endpoint	CamelContext.addEndpoint(String uri, Endpoint endpoint)	Adds and starts the endpoint to the EndpointRegistry using the given URI.
CompletableFuture<Object>	ProducerTemplate.asyncRequestBody(Endpoint endpoint, Object body)	Sends an asynchronous body to the given endpoint.
<T> CompletableFuture<T>	ProducerTemplate.asyncRequestBody(Endpoint endpoint, Object body, Class<T> type)	Sends an asynchronous body to the given endpoint.
CompletableFuture<Object>	ProducerTemplate.asyncRequestBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue)	Sends an asynchronous body to the given endpoint.
<T> CompletableFuture<T>	ProducerTemplate.asyncRequestBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue, Class<T> type)	Sends an asynchronous body to the given endpoint.
CompletableFuture<Object>	ProducerTemplate.asyncRequestBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers)	Sends an asynchronous body to the given endpoint.
<T> CompletableFuture<T>	ProducerTemplate.asyncRequestBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers, Class<T> type)	Sends an asynchronous body to the given endpoint.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(Endpoint endpoint, Exchange exchange)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(Endpoint endpoint, Processor processor)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Object>	ProducerTemplate.asyncSendBody(Endpoint endpoint, Object body)	Sends an asynchronous body to the given endpoint.
Exchange	ConsumerTemplate.receive(Endpoint endpoint)	Receives from the endpoint, waiting until there is a response.
@Nullable Exchange	ConsumerTemplate.receive(Endpoint endpoint, long timeout)	Receives from the endpoint, waiting until there is a response or the timeout occurs
@Nullable Object	ConsumerTemplate.receiveBody(Endpoint endpoint)	Receives from the endpoint, waiting until there is a response
@Nullable Object	ConsumerTemplate.receiveBody(Endpoint endpoint, long timeout)	Receives from the endpoint, waiting until there is a response or the timeout occurs
<T> @Nullable T	ConsumerTemplate.receiveBody(Endpoint endpoint, long timeout, Class<T> type)	Receives from the endpoint, waiting until there is a response or the timeout occurs
<T> @Nullable T	ConsumerTemplate.receiveBody(Endpoint endpoint, Class<T> type)	Receives from the endpoint, waiting until there is a response
@Nullable Object	ConsumerTemplate.receiveBodyNoWait(Endpoint endpoint)	Receives from the endpoint, not waiting for a response if none exists.
<T> @Nullable T	ConsumerTemplate.receiveBodyNoWait(Endpoint endpoint, Class<T> type)	Receives from the endpoint, not waiting for a response if none exists.
@Nullable Exchange	ConsumerTemplate.receiveNoWait(Endpoint endpoint)	Receives from the endpoint, not waiting for a response if none exists.
void	CamelContext.removeEndpoint(Endpoint endpoint)	Removes the endpoint from the EndpointRegistry.
Exchange	ProducerTemplate.request(Endpoint endpoint, Processor processor)	Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern.
@Nullable Object	ProducerTemplate.requestBody(Endpoint endpoint, Object body)	Send the body to an endpoint returning any result output body.
<T> @Nullable T	ProducerTemplate.requestBody(Endpoint endpoint, Object body, Class<T> type)	Send the body to an endpoint returning any result output body.
@Nullable Object	ProducerTemplate.requestBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue)	Send the body to an endpoint returning any result output body.
<T> @Nullable T	ProducerTemplate.requestBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue, Class<T> type)	Send the body to an endpoint returning any result output body.
@Nullable Object	ProducerTemplate.requestBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers)	Sends the body to an endpoint with the specified headers and header values.
<T> @Nullable T	ProducerTemplate.requestBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers, Class<T> type)	Sends the body to an endpoint with the specified headers and header values.
Exchange	ProducerTemplate.send(Endpoint endpoint, Exchange exchange)	Sends the exchange to the given endpoint
Exchange	ProducerTemplate.send(Endpoint endpoint, ExchangePattern pattern, Processor processor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(Endpoint endpoint, ExchangePattern pattern, Processor processor, Processor resultProcessor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(Endpoint endpoint, Processor processor)	Sends an exchange to an endpoint using a supplied processor
void	ProducerTemplate.sendBody(Endpoint endpoint, Object body)	Send the body to an endpoint
@Nullable Object	ProducerTemplate.sendBody(Endpoint endpoint, ExchangePattern pattern, Object body)	Send the body to an endpoint with the given ExchangePattern returning any result output body
void	ProducerTemplate.sendBodyAndHeader(Endpoint endpoint, Object body, String header, Object headerValue)	Sends the body to an endpoint with a specified header and header value
@Nullable Object	ProducerTemplate.sendBodyAndHeader(Endpoint endpoint, ExchangePattern pattern, Object body, String header, Object headerValue)	Sends the body to an endpoint with a specified header and header value
void	ProducerTemplate.sendBodyAndHeaders(Endpoint endpoint, Object body, Map<String,Object> headers)	Sends the body to an endpoint with the specified headers and header values
@Nullable Object	ProducerTemplate.sendBodyAndHeaders(Endpoint endpoint, ExchangePattern pattern, Object body, Map<String,Object> headers)	Sends the body to an endpoint with the specified headers and header values
void	ProducerTemplate.sendBodyAndProperty(Endpoint endpoint, Object body, String property, Object propertyValue)	Sends the body to an endpoint with a specified property and property value
@Nullable Object	ProducerTemplate.sendBodyAndProperty(Endpoint endpoint, ExchangePattern pattern, Object body, String property, Object propertyValue)	Sends the body to an endpoint with a specified property and property value
void	FluentProducerTemplate.setDefaultEndpoint(Endpoint defaultEndpoint)	Sets the default endpoint to use if none is specified
void	ProducerTemplate.setDefaultEndpoint(Endpoint defaultEndpoint)	Sets the default endpoint to use if none is specified
void	ExchangeExtension.setFromEndpoint(Endpoint fromEndpoint)	Sets the endpoint which originated this message exchange.
FluentProducerTemplate	FluentProducerTemplate.to(Endpoint endpoint)	Endpoint to send to
FluentProducerTemplate	FluentProducerTemplate.withDefaultEndpoint(Endpoint endpoint)	Sets the default endpoint

Constructors in org.apache.camel with parameters of type Endpoint

Modifier	Constructor	Description
	FailedToCreateConsumerException(Endpoint endpoint, String message)
	FailedToCreateConsumerException(Endpoint endpoint, String message, Throwable cause)
	FailedToCreateConsumerException(Endpoint endpoint, Throwable cause)
	FailedToCreateProducerException(Endpoint endpoint, Throwable cause)
	ProxyInstantiationException(Class<?> type, Endpoint endpoint, Throwable cause)

Uses of Endpoint in org.apache.camel.spi

Subinterfaces of Endpoint in org.apache.camel.spi

Modifier and Type	Interface	Description
interface	BrowsableEndpoint	An optional interface an Endpoint may choose to implement which allows it to expose a way of browsing the exchanges available.
interface	InterceptSendToEndpoint	An Endpoint wrapper that, when sent to, detours the exchange: before, send to the original endpoint (which can be skipped), then after (optional).

Subinterfaces with type arguments of type Endpoint in org.apache.camel.spi

Modifier and Type	Interface	Description
interface	EndpointRegistry	Registry to cache endpoints in memory.

Methods in org.apache.camel.spi that return Endpoint

Modifier and Type	Method	Description
Endpoint	CamelEvent.ExchangeSendingEvent.getEndpoint()	Returns the destination endpoint.
Endpoint	CamelEvent.ExchangeSentEvent.getEndpoint()	Returns the destination endpoint.
Endpoint	InterceptSendToEndpoint.getOriginalEndpoint()	The original endpoint which was intercepted.
Endpoint	EndpointStrategy.registerEndpoint(String uri, Endpoint endpoint)	Register the endpoint.

Methods in org.apache.camel.spi that return types with arguments of type Endpoint

Modifier and Type	Method	Description
Map<String,Endpoint>	EndpointRegistry.getReadOnlyMap()	Gets a read-only map of the endpoints currently in the registry.
Collection<Endpoint>	EndpointRegistry.getReadOnlyValues()	Gets a read-only collection of the endpoints currently in the registry.

Methods in org.apache.camel.spi with parameters of type Endpoint

Modifier and Type	Method	Description
PollingConsumer	ConsumerCache.acquirePollingConsumer(Endpoint endpoint)	Acquires a pooled polling consumer which you must release back again after usage using the ConsumerCache.releasePollingConsumer(Endpoint, PollingConsumer) method.
AsyncProducer	ProducerCache.acquireProducer(Endpoint endpoint)	Acquires a pooled producer which you must release back again after usage using the ProducerCache.releaseProducer(org.apache.camel.Endpoint, org.apache.camel.AsyncProducer) method.
CompletableFuture<Exchange>	ProducerCache.asyncSendExchange(Endpoint endpoint, ExchangePattern pattern, Processor processor, @Nullable Processor resultProcessor, @Nullable Exchange exchange, @Nullable CompletableFuture<Exchange> future)	Asynchronously sends an exchange to an endpoint using a supplied Processor to populate the exchange
boolean	PollingConsumerPollStrategy.begin(Consumer consumer, Endpoint endpoint)	Called when poll is about to begin
void	PollingConsumerPollStrategy.commit(Consumer consumer, Endpoint endpoint, int polledMessages)	Called when poll is completed successfully
Exchange	ExchangeFactory.create(Endpoint fromEndpoint, boolean autoRelease)	Gets a new Exchange
Exchange	ProcessorExchangeFactory.create(Endpoint fromEndpoint, ExchangePattern exchangePattern)	Gets a new Exchange
AsyncProducer	InternalProcessorFactory.createAsyncProducer(Endpoint endpoint)
CamelEvent	EventFactory.createExchangeSendingEvent(Exchange exchange, Endpoint endpoint)	Creates an CamelEvent when an Exchange is about to be sent to the endpoint (eg before).
CamelEvent	EventFactory.createExchangeSentEvent(Exchange exchange, Endpoint endpoint, long timeTaken)	Creates an CamelEvent when an Exchange has completely been sent to the endpoint (eg after).
InterceptSendToEndpoint	InterceptEndpointFactory.createInterceptSendToEndpoint(CamelContext camelContext, Endpoint endpoint, boolean skip, @Nullable Predicate onWhen, @Nullable Processor before, @Nullable Processor after)	Creates an endpoint when intercepting sending to an endpoint (detour).
AsyncProducer	InternalProcessorFactory.createInterceptSendToEndpointProcessor(InterceptSendToEndpoint endpoint, Endpoint delegate, AsyncProducer producer, boolean skip, @Nullable Predicate onWhen)
Producer	DeferServiceFactory.createProducer(Endpoint endpoint)	Creates the Producer which is deferred started until CamelContext is being started.
Producer	InternalProcessorFactory.createProducer(Endpoint endpoint)
<T> T	BeanProxyFactory.createProxy(Endpoint endpoint, boolean binding, Class<T>... interfaceClasses)	Creates a proxy bean facade with the interfaces that when invoked will send the data as a message to a Camel endpoint.
Route	RouteFactory.createRoute(CamelContext camelContext, NamedNode routeDefinition, String routeId, @Nullable String routeDescription, @Nullable String routeNote, Endpoint endpoint, @Nullable Resource resource)	Creates the route which should be configured afterwards with more configurations.
boolean	ProducerCache.doInAsyncProducer(Endpoint endpoint, Exchange exchange, AsyncCallback callback, ProducerCache.AsyncProducerCallback producerCallback)	Sends an exchange to an endpoint using a supplied callback supporting the asynchronous routing engine.
Object	ManagementObjectStrategy.getManagedObjectForEndpoint(CamelContext context, Endpoint endpoint)
ObjectName	ManagementObjectNameStrategy.getObjectNameForEndpoint(Endpoint endpoint)
void	LifecycleStrategy.onEndpointAdd(Endpoint endpoint)	Notification on adding an Endpoint.
void	LifecycleStrategy.onEndpointRemove(Endpoint endpoint)	Notification on removing an Endpoint.
@Nullable Exchange	ConsumerCache.receive(Endpoint endpoint)	Waits until a message is available and then returns it.
@Nullable Exchange	ConsumerCache.receive(Endpoint endpoint, long timeout)	Attempts to receive a message exchange, waiting up to the given timeout to expire if a message is not yet available.
@Nullable Exchange	ConsumerCache.receiveNoWait(Endpoint endpoint)	Attempts to receive a message exchange immediately without waiting and returning null if a message exchange is not available yet.
Endpoint	EndpointStrategy.registerEndpoint(String uri, Endpoint endpoint)	Register the endpoint.
void	ConsumerCache.releasePollingConsumer(Endpoint endpoint, PollingConsumer pollingConsumer)	Releases an acquired polling consumer back after usage.
void	ProducerCache.releaseProducer(Endpoint endpoint, AsyncProducer producer)	Releases an acquired producer back after usage.
boolean	PollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause)	Called when poll failed
Exchange	ProducerCache.send(Endpoint endpoint, Exchange exchange, @Nullable Processor resultProcessor)	Sends the exchange to the given endpoint.
void	Tracer.traceSentNode(NamedNode node, Exchange exchange, Endpoint endpoint, long elapsed)	Trace when an Exchange was sent to a given endpoint