Package com.netflix.eureka.cluster

Class AsgReplicationTask

java.lang.Object

com.netflix.eureka.cluster.AsgReplicationTask

public abstract class AsgReplicationTask
extends java.lang.Object

Base ReplicationTask class for ASG related replication requests.

Field Summary

Fields

Modifier and Type	Field	Description
protected PeerAwareInstanceRegistryImpl.Action	action
protected java.lang.String	peerNodeName

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AsgReplicationTask(java.lang.String peerNodeName, PeerAwareInstanceRegistryImpl.Action action, java.lang.String asgName, ASGResource.ASGStatus newStatus)

Method Summary

Modifier and Type	Method	Description
abstract com.netflix.discovery.shared.transport.EurekaHttpResponse<?>	execute()
PeerAwareInstanceRegistryImpl.Action	getAction()
java.lang.String	getAsgName()
ASGResource.ASGStatus	getNewStatus()
java.lang.String	getTaskName()
void	handleFailure(int statusCode, java.lang.Object responseEntity)
void	handleSuccess()

Methods inherited from class java.lang.Object

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

Field Detail

peerNodeName

protected final java.lang.String peerNodeName

action

protected final PeerAwareInstanceRegistryImpl.Action action

Constructor Detail

AsgReplicationTask

protected AsgReplicationTask(java.lang.String peerNodeName,
                             PeerAwareInstanceRegistryImpl.Action action,
                             java.lang.String asgName,
                             ASGResource.ASGStatus newStatus)

Method Detail

getTaskName

public java.lang.String getTaskName()

getAsgName

public java.lang.String getAsgName()

getNewStatus

public ASGResource.ASGStatus getNewStatus()

getAction

public PeerAwareInstanceRegistryImpl.Action getAction()

execute

public abstract com.netflix.discovery.shared.transport.EurekaHttpResponse<?> execute()
                                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

handleSuccess

public void handleSuccess()

handleFailure

public void handleFailure(int statusCode,
                          java.lang.Object responseEntity)
                   throws java.lang.Throwable

Throws:

java.lang.Throwable