org.openhubframework.openhub.component.asynchchild

Class AsynchChildEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.openhubframework.openhub.component.asynchchild.AsynchChildEndpoint

All Implemented Interfaces:

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

public class AsynchChildEndpoint
extends org.apache.camel.impl.DefaultEndpoint

Endpoint for asynch-child component.

Author:

Petr Juza

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
AsynchChildEndpoint(String endpointUri, AsynchChildComponent component) Creates new endpoint.

Method Summary

Modifier and Type	Method and Description
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
BindingTypeEnum	getBindingType()
String	getCorrelationId()
String	getFunnelValue()
String	getObjectId()
String	getOperationName()
String	getService()
String	getSourceSystem()
boolean	isSingleton()
void	setBindingType(BindingTypeEnum bindingType) Sets binding type, possible values are BindingTypeEnum.
void	setCorrelationId(String correlationId) Sets correlation ID.
void	setFunnelValue(String funnelValue) Sets funnel value for "funnel" filtering.
void	setObjectId(String objectId) Sets object ID that will be changed during message processing.
void	setOperationName(String operationName) Sets operation name, e.g.
void	setService(String service) Sets message service name, e.g.
void	setSourceSystem(String sourceSystem) Sets source system, e.g.

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

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, 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

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

Constructor Detail

AsynchChildEndpoint

public AsynchChildEndpoint(String endpointUri,
                           AsynchChildComponent component)

Creates new endpoint.

Parameters:

endpointUri - the URI

component - the "asynch-child" component

Method Detail

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

isSingleton

public boolean isSingleton()

getService

public String getService()

setService

public void setService(String service)

Sets message service name, e.g. "customer".

Parameters:

service - the service name

getOperationName

public String getOperationName()

setOperationName

public void setOperationName(@Nullable
                             String operationName)

Sets operation name, e.g. "createCustomer"

Parameters:

operationName - the operation name

getCorrelationId

@Nullable
public String getCorrelationId()

setCorrelationId

public void setCorrelationId(@Nullable
                             String correlationId)

Sets correlation ID.

Parameters:

correlationId - the correlation ID

getSourceSystem

@Nullable
public String getSourceSystem()

setSourceSystem

public void setSourceSystem(String sourceSystem)

Sets source system, e.g. "CRM".

Parameters:

sourceSystem - the source system

getBindingType

public BindingTypeEnum getBindingType()

setBindingType

public void setBindingType(BindingTypeEnum bindingType)

Sets binding type, possible values are BindingTypeEnum.

Parameters:

bindingType - the binding type

getObjectId

@Nullable
public String getObjectId()

setObjectId

public void setObjectId(@Nullable
                        String objectId)

Sets object ID that will be changed during message processing.

Parameters:

objectId - the object ID

getFunnelValue

@Nullable
public String getFunnelValue()

setFunnelValue

public void setFunnelValue(@Nullable
                           String funnelValue)

Sets funnel value for "funnel" filtering.

Parameters:

funnelValue - the funnel value