org.adroitlogic.x.base.connector

Class ResponseIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

java.lang.Object

org.adroitlogic.x.base.processor.AbstractProcessingElement

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

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

All Implemented Interfaces:

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

@MetricsReporter
public abstract class ResponseIngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>
extends IngressConnectorElement<L,C>

The base class that must be extended by all two way ingress connectors (ingress connectors that expect response)

Since:

17.07

Author:

Udith Gunaratna

Field Summary

Fields inherited from class org.adroitlogic.x.base.connector.IngressConnectorElement

listener

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

beanName, context, flowId, logger, project, status

Constructor Summary

Constructors

Constructor and Description
ResponseIngressConnectorElement()

Method Summary

Modifier and Type	Method and Description
long	getResponseTimeout()
ExecutionResult	process(XMessageContext messageContext)
void	setResponseTimeout(long responseTimeout)

Methods inherited from class org.adroitlogic.x.base.connector.IngressConnectorElement

getAdditionalProperties, getIngressConfig, getIntegrationFlow, getProcessingElement, initElement, newListener, populateIngressConfig, processReceivedMessage, receiveMessage, setIntegrationFlow, setProcessingElement, start, 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

Constructor Detail

ResponseIngressConnectorElement

public ResponseIngressConnectorElement()

Method Detail

process

public final ExecutionResult process(XMessageContext messageContext)

Overrides:

process in class IngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

getResponseTimeout

public long getResponseTimeout()

Specified by:

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

Overrides:

getResponseTimeout in class IngressConnectorElement<L extends ListenerConfig,C extends IngressConfig>

setResponseTimeout

public void setResponseTimeout(long responseTimeout)