Package me.hsgamer.topper.agent.storage

Class StorageAgent<K,V>

java.lang.Object

me.hsgamer.topper.agent.storage.StorageAgent<K,V>

All Implemented Interfaces:

Runnable, Agent, DataEntryAgent<K,V>

public class StorageAgent<K,V>
extends Object
implements Agent, DataEntryAgent<K,V>, Runnable

Constructor Summary

Constructors

Constructor	Description
StorageAgent(DataStorage<K,V> storage)

Method Summary

Modifier and Type	Method	Description
void	beforeStop()
Agent	getLoadAgent(DataHolder<K,V> holder)
DataStorage<K,V>	getStorage()
void	onCreate(DataEntry<K,V> entry)
void	onRemove(DataEntry<K,V> entry)
void	onUpdate(DataEntry<K,V> entry, V oldValue, V newValue)
void	run()
protected void	scheduleValue(K key, V value)
void	setLoadOnCreate(boolean loadOnCreate)
void	setMaxEntryPerCall(int taskSaveEntryPerTick)
void	setScheduleOnEntryRemove(boolean scheduleOnEntryRemove)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface me.hsgamer.topper.agent.core.DataEntryAgent

onUnregister

Constructor Details

StorageAgent

public StorageAgent(DataStorage<K,V> storage)

Method Details

scheduleValue

protected void scheduleValue(K key,
 @Nullable
 V value)

start

public void start()

Specified by:

start in interface Agent

stop

public void stop()

Specified by:

stop in interface Agent

beforeStop

public void beforeStop()

Specified by:

beforeStop in interface Agent

onCreate

public void onCreate(DataEntry<K,V> entry)

Specified by:

onCreate in interface DataEntryAgent<K,V>

onUpdate

public void onUpdate(DataEntry<K,V> entry,
 V oldValue,
 V newValue)

Specified by:

onUpdate in interface DataEntryAgent<K,V>

onRemove

public void onRemove(DataEntry<K,V> entry)

Specified by:

onRemove in interface DataEntryAgent<K,V>

run

public void run()

Specified by:

run in interface Runnable

getStorage

public DataStorage<K,V> getStorage()

setMaxEntryPerCall

public void setMaxEntryPerCall(int taskSaveEntryPerTick)

setLoadOnCreate

public void setLoadOnCreate(boolean loadOnCreate)

setScheduleOnEntryRemove

public void setScheduleOnEntryRemove(boolean scheduleOnEntryRemove)

getLoadAgent

public Agent getLoadAgent(DataHolder<K,V> holder)