@ManagedResource(description="Managed Connector Endpoint")
public class DefaultConnectorEndpoint
extends org.apache.camel.impl.DefaultEndpoint
implements org.apache.camel.DelegateEndpoint
Constructor and Description |
---|
DefaultConnectorEndpoint(String endpointUri,
ConnectorComponent component,
org.apache.camel.Endpoint endpoint,
DataType inputDataType,
DataType outputDataType) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.Processor |
getAfterConsumer()
Gets the processor used to perform custom processing when the consumer is about to send back a reply message to the caller (if InOut).
|
org.apache.camel.Processor |
getAfterProducer()
Gets the processor used to perform custom processing after the producer has sent the message and received any reply (if InOut).
|
org.apache.camel.Processor |
getBeforeConsumer()
Gets the processor used to perform custom processing when the consumer has just received a new incoming message.
|
org.apache.camel.Processor |
getBeforeProducer()
Gets the processor used to perform custom processing before the producer is sending the message.
|
ConnectorComponent |
getComponent() |
String |
getDelegateEndpointUri() |
org.apache.camel.Endpoint |
getEndpoint() |
DataType |
getInputDataType() |
DataType |
getOutputDataType() |
boolean |
isSingleton() |
void |
setAfterConsumer(org.apache.camel.Processor afterConsumer)
To perform custom processing when the consumer is about to send back a reply message to the caller (if InOut).
|
void |
setAfterProducer(org.apache.camel.Processor afterProducer)
To perform custom processing after the producer has sent the message and received any reply (if InOut).
|
void |
setBeforeConsumer(org.apache.camel.Processor beforeConsumer)
To perform custom processing when the consumer has just received a new incoming message.
|
void |
setBeforeProducer(org.apache.camel.Processor beforeProducer)
To perform custom processing before the producer is sending the message.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, 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, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public DefaultConnectorEndpoint(String endpointUri, ConnectorComponent component, org.apache.camel.Endpoint endpoint, DataType inputDataType, DataType outputDataType)
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public ConnectorComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public org.apache.camel.Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.DelegateEndpoint
@ManagedAttribute(description="Delegate Endpoint URI", mask=true) public String getDelegateEndpointUri()
@ManagedAttribute(description="Input data type") public DataType getInputDataType()
@ManagedAttribute(description="Output data type") public DataType getOutputDataType()
public org.apache.camel.Processor getBeforeProducer()
public void setBeforeProducer(org.apache.camel.Processor beforeProducer)
public org.apache.camel.Processor getAfterProducer()
public void setAfterProducer(org.apache.camel.Processor afterProducer)
public org.apache.camel.Processor getBeforeConsumer()
public void setBeforeConsumer(org.apache.camel.Processor beforeConsumer)
public org.apache.camel.Processor getAfterConsumer()
public void setAfterConsumer(org.apache.camel.Processor afterConsumer)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
Apache Camel