@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
Modifier and Type | Class and Description |
---|---|
static class |
AtlasEndpoint.TargetMapMode |
Modifier and Type | Field and Description |
---|---|
static String |
CONTENT_TYPE_JSON |
static String |
CONTENT_TYPE_XML |
Constructor and Description |
---|
AtlasEndpoint(String uri,
AtlasComponent component,
String resourceUri) |
Modifier and Type | Method and Description |
---|---|
protected String |
createEndpointUri() |
AtlasEndpoint |
findOrCreateEndpoint(String uri,
String newResourceUri) |
io.atlasmap.api.AtlasContext |
getAtlasContext() |
io.atlasmap.api.AtlasContextFactory |
getAtlasContextFactory() |
String |
getEncoding() |
org.apache.camel.ExchangePattern |
getExchangePattern() |
String |
getPropertiesFile() |
String |
getSourceMapName() |
AtlasEndpoint.TargetMapMode |
getTargetMapMode() |
String |
getTargetMapName() |
boolean |
isLoaderCache() |
boolean |
isSingleton() |
protected void |
onExchange(org.apache.camel.Exchange exchange) |
void |
setAtlasContext(io.atlasmap.api.AtlasContext atlasContext) |
void |
setAtlasContextFactory(io.atlasmap.api.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 |
setPropertiesFile(String file)
The URI of the properties file which is used for AtlasContextFactory
initialization.
|
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. |
clearContentCache, getCamelId, getCamelManagementName, getResourceAsInputStream, getResourceAsInputStreamWithoutCache, getResourceUri, getState, isContentCache, isContentCacheCleared, loadResource, setContentCache, setResourceUri
createPollingConsumer, createProcessor, createProducer, getProcessor, setProcessor
configureConsumer, configureProperties, configureScheduledPollConsumerProperties, doConfigureConsumer, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRepeatCount, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRepeatCount, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay
configurePollingConsumer, createAsyncProducer, createExchange, createExchange, doInit, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBasicPropertyBinding, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBasicPropertyBinding, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final String CONTENT_TYPE_JSON
public static final String CONTENT_TYPE_XML
public AtlasEndpoint(String uri, AtlasComponent component, String resourceUri)
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
isSingleton
in class org.apache.camel.support.DefaultEndpoint
public org.apache.camel.ExchangePattern getExchangePattern()
getExchangePattern
in class org.apache.camel.support.DefaultEndpoint
protected String createEndpointUri()
createEndpointUri
in class org.apache.camel.support.DefaultEndpoint
public io.atlasmap.api.AtlasContextFactory getAtlasContextFactory()
public void setAtlasContextFactory(io.atlasmap.api.AtlasContextFactory atlasContextFactory)
public io.atlasmap.api.AtlasContext getAtlasContext()
public void setAtlasContext(io.atlasmap.api.AtlasContext atlasContext)
public boolean isLoaderCache()
public void setLoaderCache(boolean loaderCache)
loaderCache
- true to enable loader cachepublic void setEncoding(String encoding)
encoding
- encodingpublic String getEncoding()
public void setPropertiesFile(String file)
file
- property file pathpublic String getPropertiesFile()
public void setSourceMapName(String name)
java.util.Map<String, Message>
where the key is AtlasMap Document ID.
AtlasMap consumes Message bodies as source documents.name
- Exchange property name for source mappublic String getSourceMapName()
public void setTargetMapName(String name)
java.util.Map<String, Object>
where the key is AtlasMap Document ID.
AtlasMap populates multiple target documents into this map.name
- Exchange property name for target mappublic String getTargetMapName()
public void setTargetMapMode(AtlasEndpoint.TargetMapMode mode)
AtlasEndpoint.TargetMapMode
enum value to specify how multiple documents are delivered.mode
- AtlasEndpoint.TargetMapMode
public AtlasEndpoint.TargetMapMode getTargetMapMode()
public AtlasEndpoint findOrCreateEndpoint(String uri, String newResourceUri)
Copyright © 2021 JBoss by Red Hat. All rights reserved.