org.dataone.service.cn.replication

Class ReplicationEventListener

java.lang.Object

org.dataone.service.cn.replication.ReplicationEventListener

All Implemented Interfaces:

com.hazelcast.core.EntryListener<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata>, EventListener

public class ReplicationEventListener
extends Object
implements com.hazelcast.core.EntryListener<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata>

An event listener used to manage change events on the hzSystemMetadata map. The listener queues Identifiers into the hzReplicationEvents queue when the system metadata map is added to or updated. The events queue is monitored for additions, and the ReplicationManager is called to evaluate replication policies for the given identifier and potentially create replication tasks.

Author:

cjones

Constructor Summary

Constructors

Constructor and Description
ReplicationEventListener() Constructor: create a replication event listener that listens for entry events on the hzSystemMetadata map a queues the identifier key for replication task creation.

Method Summary

Modifier and Type	Method and Description
void	entryAdded(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event) Implement the EntryListener interface, responding to entries being added to the hzSystemMetadata map.
void	entryEvicted(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event) Implement the EntryListener interface, responding to entries being evicted from the hzSystemMetadata map.
void	entryRemoved(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event) Implement the EntryListener interface, responding to entries being deleted from the hzSystemMetadata map.
void	entryUpdated(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event) Implement the EntryListener interface, responding to entries being updated in the hzSystemMetadata map.
void	init() Initialize the bean object

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationEventListener

public ReplicationEventListener()

Constructor: create a replication event listener that listens for entry events on the hzSystemMetadata map a queues the identifier key for replication task creation. Intended to be used by the ReplicationManager to manage hzSystemMetadata map events

Method Detail

init

public void init()

Initialize the bean object

entryAdded

public void entryAdded(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event)

Implement the EntryListener interface, responding to entries being added to the hzSystemMetadata map.

Specified by:

entryAdded in interface com.hazelcast.core.EntryListener<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata>

Parameters:

event - - the entry event being added to the map

entryUpdated

public void entryUpdated(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event)

Implement the EntryListener interface, responding to entries being updated in the hzSystemMetadata map.

Specified by:

entryUpdated in interface com.hazelcast.core.EntryListener<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata>

Parameters:

event - - the entry event being updated in the map

entryRemoved

public void entryRemoved(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event)

Implement the EntryListener interface, responding to entries being deleted from the hzSystemMetadata map.

Specified by:

entryRemoved in interface com.hazelcast.core.EntryListener<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata>

Parameters:

event - - the entry event being deleted from the map

entryEvicted

public void entryEvicted(com.hazelcast.core.EntryEvent<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata> event)

Implement the EntryListener interface, responding to entries being evicted from the hzSystemMetadata map.

Specified by:

entryEvicted in interface com.hazelcast.core.EntryListener<org.dataone.service.types.v1.Identifier,org.dataone.service.types.v2.SystemMetadata>

Parameters:

event - - the entry event being evicted from the map