org.openecomp.sdc.be.components.distribution.engine

Class DistributionEngineInitTask

java.lang.Object

org.openecomp.sdc.be.components.distribution.engine.DistributionEngineInitTask

All Implemented Interfaces:

Runnable

public class DistributionEngineInitTask
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALREADY_EXISTS
static String	CONSUMER
static String	CREATED
static String	FAILED
static Integer	HTTP_OK
static String	INIT_DISTRIBUTION_ENGINE_FLOW
static String	PRODUCER

Constructor Summary

Constructors

Constructor and Description
DistributionEngineInitTask(Long delayBeforeStartFlow, DistributionEngineConfiguration deConfiguration, String envName, AtomicBoolean status, ComponentsUtils componentsUtils, DistributionEnginePollingTask distributionEnginePollingTask)

Method Summary

Modifier and Type	Method and Description
static String	buildTopicName(String topicName, String environment)
void	destroy()
long	getCurrentRetryInterval()
protected void	incrementRetryInterval()
boolean	initFlow() run initialization flow
boolean	isActive()
void	restartTask()
void	run()
protected void	setCambriaHandler(CambriaHandler cambriaHandler)
void	startTask()
void	stopTask()

Methods inherited from class java.lang.Object

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

Field Detail

INIT_DISTRIBUTION_ENGINE_FLOW

public static final String INIT_DISTRIBUTION_ENGINE_FLOW

See Also:

Constant Field Values

ALREADY_EXISTS

public static final String ALREADY_EXISTS

See Also:

Constant Field Values

CONSUMER

public static final String CONSUMER

See Also:

Constant Field Values

PRODUCER

public static final String PRODUCER

See Also:

Constant Field Values

CREATED

public static final String CREATED

See Also:

Constant Field Values

FAILED

public static final String FAILED

See Also:

Constant Field Values

HTTP_OK

public static final Integer HTTP_OK

Constructor Detail

DistributionEngineInitTask

public DistributionEngineInitTask(Long delayBeforeStartFlow,
                                  DistributionEngineConfiguration deConfiguration,
                                  String envName,
                                  AtomicBoolean status,
                                  ComponentsUtils componentsUtils,
                                  DistributionEnginePollingTask distributionEnginePollingTask)

Method Detail

startTask

public void startTask()

restartTask

public void restartTask()

incrementRetryInterval

protected void incrementRetryInterval()

stopTask

public void stopTask()

destroy

public void destroy()

run

public void run()

Specified by:

run in interface Runnable

initFlow

public boolean initFlow()

run initialization flow

Returns:

buildTopicName

public static String buildTopicName(String topicName,
                                    String environment)

isActive

public boolean isActive()

getCurrentRetryInterval

public long getCurrentRetryInterval()

setCambriaHandler

protected void setCambriaHandler(CambriaHandler cambriaHandler)