org.adroitlogic.x.base.connector

Class ScheduledIngressConnectorElement<L extends ScheduledListenerConfig,C extends ScheduledIngressConfig>

java.lang.Object

org.adroitlogic.x.base.processor.AbstractProcessingElement

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

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

All Implemented Interfaces:

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

public abstract class ScheduledIngressConnectorElement<L extends ScheduledListenerConfig,C extends ScheduledIngressConfig>
extends IngressConnectorElement<L,C>

The scheduled ingress connector element that defines the base for the polling connectors

Since:

17.01

Author:

Ruwan Linton

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
ScheduledIngressConnectorElement()

Method Summary

Modifier and Type	Method and Description
L	getListenerConfig()
protected abstract L	getScheduledListenerConfig()
C	populateIngressConfig()
protected abstract C	populateScheduledIngressConfig()
void	setConcurrentPollingCount(Integer concurrentPollingCount)
void	setCronExpression(String cronExpression)
void	setParallelExecutionCount(Integer parallelExecutionCount)
void	setRepeatCount(int repeatCount)
void	setRepeatCount(Integer repeatCount)
void	setRepeatInterval(long repeatInterval)
void	setRepeatInterval(Long repeatInterval)
void	setSchedulerConfig(SchedulerConfig schedulerConfig)
void	setStartDelay(long startDelay)
void	setStartDelay(Long startDelay)

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

getAdditionalProperties, getIngressConfig, getIntegrationFlow, getProcessingElement, getResponseTimeout, initElement, newListener, process, 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.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

ScheduledIngressConnectorElement

public ScheduledIngressConnectorElement()

Method Detail

setCronExpression

public void setCronExpression(String cronExpression)

setStartDelay

public void setStartDelay(long startDelay)

setRepeatInterval

public void setRepeatInterval(long repeatInterval)

setRepeatCount

public void setRepeatCount(int repeatCount)

setSchedulerConfig

public void setSchedulerConfig(SchedulerConfig schedulerConfig)

setStartDelay

public void setStartDelay(Long startDelay)

setRepeatInterval

public void setRepeatInterval(Long repeatInterval)

setRepeatCount

public void setRepeatCount(Integer repeatCount)

setConcurrentPollingCount

public void setConcurrentPollingCount(Integer concurrentPollingCount)

setParallelExecutionCount

public void setParallelExecutionCount(Integer parallelExecutionCount)

getListenerConfig

public final L getListenerConfig()

populateIngressConfig

public final C populateIngressConfig()

Specified by:

populateIngressConfig in class IngressConnectorElement<L extends ScheduledListenerConfig,C extends ScheduledIngressConfig>

getScheduledListenerConfig

protected abstract L getScheduledListenerConfig()

populateScheduledIngressConfig

protected abstract C populateScheduledIngressConfig()