org.adroitlogic.x.base.connector

Class ScheduledIngressConfig

java.lang.Object

org.adroitlogic.x.api.connector.IngressConfig

org.adroitlogic.x.api.connector.PreDispatchedIngressConfig

org.adroitlogic.x.base.connector.ScheduledIngressConfig

public class ScheduledIngressConfig
extends PreDispatchedIngressConfig

The scheduled ingress connector configuration that holds the information related to a polling connector

Since:

17.01

Author:

Ruwan Linton

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ScheduledIngressConfig.JobConfig
class	ScheduledIngressConfig.TriggerConfig

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ScheduledIngressConfig(String connectorId, Class<? extends ScheduledMessageInjector> jobClass)

Method Summary

Modifier and Type	Method and Description
XClusterManager	getClusterManager()
int	getConcurrentPollingCount()
ScheduledIngressConfig.JobConfig	getJobConfig()
int	getParallelExecutionCount()
ScheduledIngressConfig.TriggerConfig	getTriggerConfig()
void	setClusterManager(XClusterManager xClusterManager)
(package private) void	setConcurrentPollingCount(int concurrentPollingCount)
(package private) void	setJobConfig(String name, String group)
(package private) void	setParallelExecutionCount(int parallelExecutionCount)
(package private) void	setTriggerConfig(String name, String group, long startDelay, long repeatInterval, int repeatCount)
(package private) void	setTriggerConfig(String name, String group, String cronExpression)

Methods inherited from class org.adroitlogic.x.api.connector.PreDispatchedIngressConfig

matches

Methods inherited from class org.adroitlogic.x.api.connector.IngressConfig

getConnectorId

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledIngressConfig

protected ScheduledIngressConfig(String connectorId,
                                 Class<? extends ScheduledMessageInjector> jobClass)

Method Detail

getJobConfig

public ScheduledIngressConfig.JobConfig getJobConfig()

getTriggerConfig

public ScheduledIngressConfig.TriggerConfig getTriggerConfig()

setJobConfig

void setJobConfig(String name,
                  String group)

setTriggerConfig

void setTriggerConfig(String name,
                      String group,
                      String cronExpression)

setTriggerConfig

void setTriggerConfig(String name,
                      String group,
                      long startDelay,
                      long repeatInterval,
                      int repeatCount)

getConcurrentPollingCount

public int getConcurrentPollingCount()

setConcurrentPollingCount

void setConcurrentPollingCount(int concurrentPollingCount)

getParallelExecutionCount

public int getParallelExecutionCount()

setParallelExecutionCount

void setParallelExecutionCount(int parallelExecutionCount)

getClusterManager

public XClusterManager getClusterManager()

setClusterManager

public void setClusterManager(XClusterManager xClusterManager)