public abstract class DefaultConnectorComponent extends org.apache.camel.impl.DefaultComponent implements ConnectorComponent, org.apache.camel.VerifiableComponent
Modifier | Constructor and Description |
---|---|
protected |
DefaultConnectorComponent(String componentName,
Class<?> componentClass) |
protected |
DefaultConnectorComponent(String componentName,
String className) |
protected |
DefaultConnectorComponent(String componentName,
String componentScheme,
Class<?> componentClass) |
protected |
DefaultConnectorComponent(String componentName,
String componentScheme,
String className) |
Modifier and Type | Method and Description |
---|---|
void |
addOption(String name,
Object value)
Adds a new option to the connector's options.
|
void |
addOptions(Map<String,Object> options)
Adds options to the connector's options.
|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
String |
createEndpointUri(String scheme,
Map<String,String> options)
Creates the endpoint uri based on the options from the connector.
|
protected <T> void |
doAddOption(Map<String,T> options,
String name,
T value) |
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.
|
org.apache.camel.catalog.CamelCatalog |
getCamelCatalog()
Gets the
CamelCatalog which can be used by the connector to help create the component. |
String |
getCamelConnectorJSon()
Gets the camel-connector JSon file.
|
String |
getComponentName()
Gets the connector component name
|
String |
getComponentScheme()
Gets the connector component scheme
|
String |
getConnectorName()
Gets the connector name (title)
|
Map<String,Object> |
getOptions()
A set of additional component/endpoint options to use for the base component when creating connector endpoints.
|
org.apache.camel.ComponentVerifier |
getVerifier() |
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.
|
void |
setOptions(Map<String,Object> options)
A set of additional component/endpoint options to use for the base component when creating connector endpoints.
|
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentOptions, setComponentOptions
protected DefaultConnectorComponent(String componentName, String className)
protected DefaultConnectorComponent(String componentName, String componentScheme, String className)
protected DefaultConnectorComponent(String componentName, Class<?> componentClass)
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public String createEndpointUri(String scheme, Map<String,String> options) throws URISyntaxException
ConnectorComponent
createEndpointUri
in interface ConnectorComponent
scheme
- the component nameoptions
- the options to use for creating the endpointURISyntaxException
- is thrown if error creating the endpoint uri.public org.apache.camel.catalog.CamelCatalog getCamelCatalog()
ConnectorComponent
CamelCatalog
which can be used by the connector to help create the component.getCamelCatalog
in interface ConnectorComponent
public String getCamelConnectorJSon()
ConnectorComponent
getCamelConnectorJSon
in interface ConnectorComponent
public String getConnectorName()
ConnectorComponent
getConnectorName
in interface ConnectorComponent
public String getComponentName()
ConnectorComponent
getComponentName
in interface ConnectorComponent
public String getComponentScheme()
ConnectorComponent
getComponentScheme
in interface ConnectorComponent
public Map<String,Object> getOptions()
ConnectorComponent
getOptions
in interface ConnectorComponent
public void setOptions(Map<String,Object> options)
ConnectorComponent
setOptions
in interface ConnectorComponent
public void addOption(String name, Object value)
ConnectorComponent
addOption
in interface ConnectorComponent
name
- the name of the optionvalue
- the value of the optionpublic void addOptions(Map<String,Object> options)
ConnectorComponent
addOptions
in interface ConnectorComponent
options
- the optionspublic org.apache.camel.ComponentVerifier getVerifier()
getVerifier
in interface org.apache.camel.VerifiableComponent
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
public org.apache.camel.Processor getBeforeProducer()
ConnectorComponent
getBeforeProducer
in interface ConnectorComponent
public void setBeforeProducer(org.apache.camel.Processor beforeProducer)
ConnectorComponent
setBeforeProducer
in interface ConnectorComponent
public org.apache.camel.Processor getAfterProducer()
ConnectorComponent
getAfterProducer
in interface ConnectorComponent
public void setAfterProducer(org.apache.camel.Processor afterProducer)
ConnectorComponent
setAfterProducer
in interface ConnectorComponent
public org.apache.camel.Processor getBeforeConsumer()
ConnectorComponent
getBeforeConsumer
in interface ConnectorComponent
public void setBeforeConsumer(org.apache.camel.Processor beforeConsumer)
ConnectorComponent
setBeforeConsumer
in interface ConnectorComponent
public org.apache.camel.Processor getAfterConsumer()
ConnectorComponent
getAfterConsumer
in interface ConnectorComponent
public void setAfterConsumer(org.apache.camel.Processor afterConsumer)
ConnectorComponent
setAfterConsumer
in interface ConnectorComponent
Apache Camel