org.apache.ambari.server.agent.stomp

Class MetadataHolder

java.lang.Object

org.apache.ambari.server.agent.stomp.AgentDataHolder<T>

org.apache.ambari.server.agent.stomp.AgentClusterDataHolder<MetadataUpdateEvent>

org.apache.ambari.server.agent.stomp.MetadataHolder

public class MetadataHolder
extends AgentClusterDataHolder<MetadataUpdateEvent>

Field Summary

Fields inherited from class org.apache.ambari.server.agent.stomp.AgentClusterDataHolder

STOMPUpdatePublisher

Fields inherited from class org.apache.ambari.server.agent.stomp.AgentDataHolder

updateLock

Constructor Summary

Constructors

Constructor and Description
MetadataHolder(AmbariEventPublisher ambariEventPublisher)

Method Summary

Modifier and Type	Method and Description
MetadataUpdateEvent	getCurrentData() Builds an update with the full set of current data.
MetadataUpdateEvent	getDeleteMetadata(Long clusterId)
protected MetadataUpdateEvent	getEmptyData()
protected boolean	handleUpdate(MetadataUpdateEvent update) Handle an incremental update to the data.
void	onAmbariPropertiesChange(AmbariPropertiesChangedEvent event)
void	onClusterComponentsRepoUpdate(ClusterComponentsRepoChangedEvent clusterComponentsRepoChangedEvent)
void	onServiceCreate(ServiceInstalledEvent serviceInstalledEvent)
void	onServiceCredentialStoreUpdate(ServiceCredentialStoreUpdateEvent serviceCredentialStoreUpdateEvent)

Methods inherited from class org.apache.ambari.server.agent.stomp.AgentClusterDataHolder

getData, getUpdateIfChanged, initializeDataIfNeeded, updateData

Methods inherited from class org.apache.ambari.server.agent.stomp.AgentDataHolder

getHash, getHash, isIdentifierValid, regenerateDataIdentifiers

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataHolder

@Inject
public MetadataHolder(AmbariEventPublisher ambariEventPublisher)

Method Detail

getCurrentData

public MetadataUpdateEvent getCurrentData()
                                   throws org.apache.ambari.server.AmbariException

Description copied from class: AgentClusterDataHolder

Builds an update with the full set of current data. The eventType should be "CREATE", if applicable.

Specified by:

getCurrentData in class AgentClusterDataHolder<MetadataUpdateEvent>

Throws:

org.apache.ambari.server.AmbariException

getDeleteMetadata

public MetadataUpdateEvent getDeleteMetadata(Long clusterId)
                                      throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleUpdate

protected boolean handleUpdate(MetadataUpdateEvent update)
                        throws org.apache.ambari.server.AmbariException

Description copied from class: AgentClusterDataHolder

Handle an incremental update to the data.

Specified by:

handleUpdate in class AgentClusterDataHolder<MetadataUpdateEvent>

Returns:

true if the update introduced any change

Throws:

org.apache.ambari.server.AmbariException

getEmptyData

protected MetadataUpdateEvent getEmptyData()

Specified by:

getEmptyData in class AgentDataHolder<MetadataUpdateEvent>

onServiceCreate

public void onServiceCreate(ServiceInstalledEvent serviceInstalledEvent)
                     throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

onClusterComponentsRepoUpdate

public void onClusterComponentsRepoUpdate(ClusterComponentsRepoChangedEvent clusterComponentsRepoChangedEvent)
                                   throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

onServiceCredentialStoreUpdate

public void onServiceCredentialStoreUpdate(ServiceCredentialStoreUpdateEvent serviceCredentialStoreUpdateEvent)
                                    throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

onAmbariPropertiesChange

public void onAmbariPropertiesChange(AmbariPropertiesChangedEvent event)
                              throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException