Package com.illumon.iris.db.v2

Class ShiftAwareSwapListener

java.lang.Object

com.illumon.util.referencecounting.ReferenceCounted

com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

com.illumon.iris.db.util.liveness.LivenessArtifact

com.illumon.iris.db.v2.SwapListenerBase<ShiftAwareListener>

com.illumon.iris.db.v2.ShiftAwareSwapListener

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, ListenerBase, ShiftAwareListener, Serializable

public class ShiftAwareSwapListener
extends SwapListenerBase<ShiftAwareListener>
implements ShiftAwareListener

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.ShiftAwareListener

ShiftAwareListener.Update

Field Summary

Fields inherited from class com.illumon.iris.db.v2.SwapListenerBase

DEBUG

Constructor Summary

Constructors

Constructor	Description
ShiftAwareSwapListener(com.fishlib.io.logger.Logger log, BaseTable sourceTable)

Method Summary

Modifier and Type	Method	Description
void	destroy()	Attempt to release (destructively when necessary) resources held by this object.
NotificationQueue.IndexUpdateNotification	getNotification(ShiftAwareListener.Update update)	Creates a notification for the table changes.
void	onUpdate(ShiftAwareListener.Update upstream)	Process notification of table changes.
void	subscribeForUpdates()	Invoke DynamicTable.listenForUpdates(Listener) for the appropriate subclass of SwapListenerBase.

Methods inherited from class com.illumon.iris.db.v2.SwapListenerBase

end, getErrorNotification, makeSnapshotControl, onFailure, setListenerAndResult, start

Methods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact

manageWithCurrentScope, unmanage, unmanage

Methods inherited from class com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

dropReference, getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryRetainReference

Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.v2.ListenerBase

getErrorNotification, onFailure

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessManager

manage, tryManage

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

Constructor Details

ShiftAwareSwapListener

public ShiftAwareSwapListener(com.fishlib.io.logger.Logger log,
 BaseTable sourceTable)

Method Details

onUpdate

public void onUpdate(ShiftAwareListener.Update upstream)

Description copied from interface: ShiftAwareListener

Process notification of table changes.

The Listener onUpdate call executes within the LiveTableMonitor refresh loop. Any tables used within the listener's onUpdate call must have already been refreshed. Using the typical pattern of a Listener that is listening to a single table, with DynamicTable.listenForUpdates(Listener), this is trivially true.

When the listener must reference more than just one parent, the tables (or other objects) it references, must be made a NotificationQueue.Dependency of the listener. For listeners that reference multiple ticking tables, a common pattern is to use a MergedListener and collection of ListenerRecorders.

Specified by:

onUpdate in interface ShiftAwareListener

Parameters:

upstream - The set of upstream table updates.

getNotification

public NotificationQueue.IndexUpdateNotification getNotification(ShiftAwareListener.Update update)

Description copied from interface: ShiftAwareListener

Creates a notification for the table changes.

Specified by:

getNotification in interface ShiftAwareListener

Parameters:

update - The set of upstream table updates.

Returns:

table change notification

destroy

public void destroy()

Description copied from class: ReferenceCountedLivenessNode

Attempt to release (destructively when necessary) resources held by this object. This may render the object unusable for subsequent operations. Implementations should be sure to call super.destroy().

This is intended to only ever be used as a side effect of decreasing the reference count to 0.

Overrides:

destroy in class ReferenceCountedLivenessNode

subscribeForUpdates

public void subscribeForUpdates()

Description copied from class: SwapListenerBase

Invoke DynamicTable.listenForUpdates(Listener) for the appropriate subclass of SwapListenerBase.

Specified by:

subscribeForUpdates in class SwapListenerBase<ShiftAwareListener>