@UriEndpoint(scheme="ref",
title="Ref",
syntax="ref:name",
label="core,endpoint")
public class RefEndpoint
extends DefaultEndpoint
implements DelegateEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
RefEndpoint(String endpointUri,
Component 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
|
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
Endpoint |
getEndpoint()
Gets the delegated
Endpoint. |
String |
getName() |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
setName(String name)
Name of endpoint to lookup in the registry.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, 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, suspendclone, finalize, getClass, notify, notifyAll, wait, wait, waitconfigureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointConfiguration, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContextpublic String getName()
public void setName(String name)
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 Endpoint getEndpoint()
DelegateEndpointEndpoint.getEndpoint in interface DelegateEndpointprotected 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