org.dataone.cn.batch.synchronization.listener

Class NodeTopicListener

java.lang.Object

org.dataone.cn.batch.synchronization.listener.NodeTopicListener

All Implemented Interfaces:

com.hazelcast.core.MessageListener<org.dataone.service.types.v1.NodeReference>, EventListener

public class NodeTopicListener
extends Object
implements com.hazelcast.core.MessageListener<org.dataone.service.types.v1.NodeReference>

Listen to the nodeTopic for any messages. if a message is received, then call back to manage the harvest jobs in HarvestSchedulingManager

Author:

waltz

Constructor Summary

Constructors

Constructor and Description
NodeTopicListener()

Method Summary

Modifier and Type	Method and Description
void	addListener()
HarvestSchedulingManager	getHarvestSchedulingManager()
void	onMessage(com.hazelcast.core.Message<org.dataone.service.types.v1.NodeReference> message)
void	setHarvestSchedulingManager(HarvestSchedulingManager harvestSchedulingManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeTopicListener

public NodeTopicListener()

Method Detail

addListener

public void addListener()

getHarvestSchedulingManager

public HarvestSchedulingManager getHarvestSchedulingManager()

setHarvestSchedulingManager

public void setHarvestSchedulingManager(HarvestSchedulingManager harvestSchedulingManager)

onMessage

public void onMessage(com.hazelcast.core.Message<org.dataone.service.types.v1.NodeReference> message)

Specified by:

onMessage in interface com.hazelcast.core.MessageListener<org.dataone.service.types.v1.NodeReference>