@UriEndpoint(scheme="binding",
title="Binding",
syntax="binding:bindingName:delegateUri",
consumerClass=BindingConsumerProcessor.class,
label="core,transformation")
public class BindingEndpoint
extends DefaultEndpoint
implements HasBinding
Binding to an underlying Endpoint so that the binding processes messages
before its sent to the endpoint and processes messages received by the endpoint consumer before its passed
to the real consumer.shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
BindingEndpoint(String uri,
Component component,
Binding binding,
Endpoint delegate)
Deprecated.
|
BindingEndpoint(String uri,
Component component,
String bindingName,
String delegateUri) |
| 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
|
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
Binding |
getBinding()
Returns the binding for this endpoint if one can be deduced or is associated
|
String |
getBindingName()
Name of the binding to lookup in the Camel registry.
|
Endpoint |
getDelegate() |
String |
getDelegateUri()
Uri of the delegate endpoint.
|
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
pipelineBindingProcessor(Processor bindingProcessor,
Exchange exchange,
Processor delegateProcessor)
Applies the
Binding processor to the given exchange before passing it on to the delegateProcessor (either a producer or consumer) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend@Deprecated public BindingEndpoint(String uri, Component component, Binding binding, Endpoint delegate)
public BindingEndpoint(String uri, Component component, String bindingName, String delegateUri)
public Producer createProducer() throws Exception
EndpointcreateProducer in interface EndpointException - can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
EndpointcreateConsumer in interface Endpointprocessor - the given processorException - can be thrownpublic boolean isSingleton()
IsSingletonisSingleton in interface IsSingletonpublic Binding getBinding()
HasBindinggetBinding in interface HasBindingpublic Endpoint getDelegate()
public String getBindingName()
public String getDelegateUri()
public void pipelineBindingProcessor(Processor bindingProcessor, Exchange exchange, Processor delegateProcessor) throws Exception
Binding processor to the given exchange before passing it on to the delegateProcessor (either a producer or consumer)Exceptionprotected void doStart() throws Exception
ServiceSupportServiceSupport.doStop() for more details.doStart in class DefaultEndpointExceptionServiceSupport.doStop()protected void doStop() throws Exception
ServiceSupportServiceSupport.doStop() method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext is shutting down.doStop in class DefaultEndpointExceptionServiceSupport.doStart()Apache Camel