Package org.apache.camel.component.atlasmap

Class AtlasEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.impl.ScheduledPollEndpoint

org.apache.camel.impl.DefaultPollingEndpoint

org.apache.camel.impl.ProcessorEndpoint

org.apache.camel.component.ResourceEndpoint

org.apache.camel.component.atlasmap.AtlasEndpoint

All Implemented Interfaces:

org.apache.camel.api.management.mbean.ManagedResourceEndpointMBean, org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

@UriEndpoint(firstVersion="2.19.0",
             scheme="atlas",
             title="AtlasMap",
             syntax="atlas:resourceUri",
             producerOnly=true,
             label="transformation")
public class AtlasEndpoint
extends org.apache.camel.component.ResourceEndpoint

Transforms the message using an AtlasMap transformation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	AtlasEndpoint.TargetMapMode

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONTENT_TYPE_JSON
static final String	CONTENT_TYPE_XML

Fields inherited from class org.apache.camel.component.ResourceEndpoint

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor	Description
AtlasEndpoint(String uri, AtlasComponent component, String resourceUri)

Method Summary

Modifier and Type	Method	Description
protected String	createEndpointUri()
AtlasEndpoint	findOrCreateEndpoint(String uri, String newResourceUri)
AtlasContext	getAtlasContext()
AtlasContextFactory	getAtlasContextFactory()
String	getEncoding()
org.apache.camel.ExchangePattern	getExchangePattern()
String	getSourceMapName()
AtlasEndpoint.TargetMapMode	getTargetMapMode()
String	getTargetMapName()
boolean	isLoaderCache()
boolean	isSingleton()
protected void	onExchange(org.apache.camel.Exchange exchange)
void	setAtlasContext(AtlasContext atlasContext)
void	setAtlasContextFactory(AtlasContextFactory atlasContextFactory)
void	setEncoding(String encoding)	Character encoding of the resource content.
void	setLoaderCache(boolean loaderCache)	Enables / disables the atlas map resource loader cache which is enabled by default.
void	setSourceMapName(String name)	The Exchange property name for a source message map which hold java.util.Map<String, Message> where the key is AtlasMap Document ID.
void	setTargetMapMode(AtlasEndpoint.TargetMapMode mode)	AtlasEndpoint.TargetMapMode enum value to specify how multiple documents are delivered.
void	setTargetMapName(String name)	The Exchange property name for a target document map which hold java.util.Map<String, Object> where the key is AtlasMap Document ID.

Methods inherited from class org.apache.camel.component.ResourceEndpoint

clearContentCache, getCamelId, getCamelManagementName, getResourceAsInputStream, getResourceAsInputStreamWithoutCache, getResourceUri, getState, isAllowContextMapAll, isContentCache, isContentCacheCleared, loadResource, setAllowContextMapAll, setContentCache, setResourceUri

Methods inherited from class org.apache.camel.impl.ProcessorEndpoint

createPollingConsumer, createProcessor, createProducer, getProcessor, setProcessor

Methods inherited from class org.apache.camel.impl.DefaultPollingEndpoint

createConsumer

Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint

configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, createEndpointConfiguration, createExchange, createExchange, createExchange, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Field Details

CONTENT_TYPE_JSON

public static final String CONTENT_TYPE_JSON

See Also:

• Constant Field Values

CONTENT_TYPE_XML

public static final String CONTENT_TYPE_XML

See Also:

• Constant Field Values

Constructor Details

AtlasEndpoint

public AtlasEndpoint(String uri,
 AtlasComponent component,
 String resourceUri)

Method Details

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

Overrides:

isSingleton in class org.apache.camel.impl.ProcessorEndpoint

getExchangePattern

public org.apache.camel.ExchangePattern getExchangePattern()

Overrides:

getExchangePattern in class org.apache.camel.impl.DefaultEndpoint

createEndpointUri

protected String createEndpointUri()

Overrides:

createEndpointUri in class org.apache.camel.impl.DefaultEndpoint

getAtlasContextFactory

public AtlasContextFactory getAtlasContextFactory()

setAtlasContextFactory

public void setAtlasContextFactory(AtlasContextFactory atlasContextFactory)

getAtlasContext

public AtlasContext getAtlasContext()

setAtlasContext

public void setAtlasContext(AtlasContext atlasContext)

isLoaderCache

public boolean isLoaderCache()

setLoaderCache

public void setLoaderCache(boolean loaderCache)

Enables / disables the atlas map resource loader cache which is enabled by default.

Parameters:

loaderCache - true to enable loader cache

setEncoding

public void setEncoding(String encoding)

Character encoding of the resource content.

Parameters:

encoding - encoding

getEncoding

public String getEncoding()

setSourceMapName

public void setSourceMapName(String name)

The Exchange property name for a source message map which hold java.util.Map<String, Message> where the key is AtlasMap Document ID. AtlasMap consumes Message bodies as source documents.

Parameters:

name - Exchange property name for source map

getSourceMapName

public String getSourceMapName()

setTargetMapName

public void setTargetMapName(String name)

The Exchange property name for a target document map which hold java.util.Map<String, Object> where the key is AtlasMap Document ID. AtlasMap populates multiple target documents into this map.

Parameters:

name - Exchange property name for target map

getTargetMapName

public String getTargetMapName()

setTargetMapMode

public void setTargetMapMode(AtlasEndpoint.TargetMapMode mode)

AtlasEndpoint.TargetMapMode enum value to specify how multiple documents are delivered.

Parameters:

mode - AtlasEndpoint.TargetMapMode

getTargetMapMode

public AtlasEndpoint.TargetMapMode getTargetMapMode()

findOrCreateEndpoint

public AtlasEndpoint findOrCreateEndpoint(String uri,
 String newResourceUri)

onExchange

protected void onExchange(org.apache.camel.Exchange exchange)
                   throws Exception

Overrides:

onExchange in class org.apache.camel.impl.ProcessorEndpoint

Throws:

Exception