org.adroitlogic.x.base.connector

Class IngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

java.lang.Object

org.adroitlogic.x.base.processor.AbstractProcessingElement

org.adroitlogic.x.base.connector.IngressConnectorElement<L,C>

All Implemented Interfaces:

XIngressConnectorElement<L,C>, Initializable, Startable, MetricsReportable, XProcessingElement, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

ResponseIngressConnectorElement, ScheduledIngressConnectorElement

@MetricsReporter
public abstract class IngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>
extends AbstractProcessingElement
implements XIngressConnectorElement<L,C>, MetricsReportable

The base class that defines an IngressConnector. All ingress connectors must inherit this class

Since:

17.01

Author:

Ruwan Linton

Field Summary

Fields

Modifier and Type	Field and Description
protected TransportListener<L,C>	listener

Fields inherited from class org.adroitlogic.x.base.processor.AbstractProcessingElement

beanName, context, flowId, logger, project, status

Constructor Summary

Constructors

Constructor and Description
IngressConnectorElement()

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getAdditionalProperties() Returns a map of additional properties to be set in the metrics records
C	getIngressConfig()
XIntegrationFlow	getIntegrationFlow()
XProcessingElement	getProcessingElement()
long	getResponseTimeout()
void	initElement(org.springframework.context.ApplicationContext context)
protected abstract TransportListener<L,C>	newListener(org.springframework.context.ApplicationContext context) Supplier implementations should just create the listener and return, initialization and starting of the listener will be handled by the framework
protected abstract C	populateIngressConfig()
ExecutionResult	process(XMessageContext messageContext)
protected ExecutionResult	processReceivedMessage(XMessageContext messageContext)
ExecutionResult	receiveMessage(XMessageContext messageContext)
void	setIntegrationFlow(XIntegrationFlow integrationFlow)
void	setProcessingElement(XProcessingElement processingElement)
void	start()
void	stop()

Methods inherited from class org.adroitlogic.x.base.processor.AbstractProcessingElement

destroy, destroyElement, getBeanName, getEntityId, getErrorHandler, getFlowId, getMetricsEngine, getProject, getProjectId, getProjectVersion, getResource, getServerConfig, getStatus, init, processMessage, setBeanName, setErrorHandler, setFlowId, setProject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.adroitlogic.x.api.connector.XIngressConnectorElement

getListenerConfig

Methods inherited from interface org.adroitlogic.x.api.processor.XProcessingElement

cast, getBeanName, getFlowId, getProject, getStatus, processMessage, setFlowId, setProject

Methods inherited from interface org.adroitlogic.x.api.dec.Initializable

destroy, init

Methods inherited from interface org.springframework.beans.factory.BeanNameAware

setBeanName

Methods inherited from interface org.adroitlogic.x.api.metrics.MetricsReportable

getEntityId, getFlowId, getMetricsEngine, getProjectId, getProjectVersion

Field Detail

listener

protected TransportListener<L extends ListenerConfig,C extends IngressConfig> listener

Constructor Detail

IngressConnectorElement

public IngressConnectorElement()

Method Detail

initElement

public final void initElement(org.springframework.context.ApplicationContext context)

Overrides:

initElement in class AbstractProcessingElement

getIngressConfig

public final C getIngressConfig()

Specified by:

getIngressConfig in interface XIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

populateIngressConfig

protected abstract C populateIngressConfig()

start

public final void start()

Specified by:

start in interface Startable

stop

public final void stop()

Specified by:

stop in interface Startable

setProcessingElement

public void setProcessingElement(XProcessingElement processingElement)

Specified by:

setProcessingElement in interface XIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

receiveMessage

public final ExecutionResult receiveMessage(XMessageContext messageContext)

Specified by:

receiveMessage in interface XIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

processReceivedMessage

protected ExecutionResult processReceivedMessage(XMessageContext messageContext)

process

public ExecutionResult process(XMessageContext messageContext)

Specified by:

process in class AbstractProcessingElement

getProcessingElement

public XProcessingElement getProcessingElement()

newListener

protected abstract TransportListener<L,C> newListener(org.springframework.context.ApplicationContext context)

Supplier implementations should just create the listener and return, initialization and starting of the listener will be handled by the framework

Parameters:

context - the application context used for the creation of the listener

Returns:

the created listener instance

getResponseTimeout

public long getResponseTimeout()

Specified by:

getResponseTimeout in interface XIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

getIntegrationFlow

public XIntegrationFlow getIntegrationFlow()

Specified by:

getIntegrationFlow in interface XIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

setIntegrationFlow

public void setIntegrationFlow(XIntegrationFlow integrationFlow)

getAdditionalProperties

public Map<String,String> getAdditionalProperties()

Returns a map of additional properties to be set in the metrics records

Specified by:

getAdditionalProperties in interface MetricsReportable

Overrides:

getAdditionalProperties in class AbstractProcessingElement

Returns:

additional properties