com.neurosys.q.notification.track.service

Class DefaultTokenNotificationTrackerService<T extends Token<T>>

java.lang.Object

com.neurosys.q.notification.track.service.DefaultTokenNotificationTrackerService<T>

All Implemented Interfaces:

TokenNotificationTrackerService<T>

public class DefaultTokenNotificationTrackerService<T extends Token<T>>
extends Object
implements TokenNotificationTrackerService<T>

A default volatile in-memory tracker TODO: Add Unit Test case

Author:

Arjun Dhar

See Also:

StoreMap

Field Summary

Fields

Modifier and Type	Field and Description
protected StoreMap<String,Integer>	countMap

Constructor Summary

Constructors

Constructor and Description
DefaultTokenNotificationTrackerService()
DefaultTokenNotificationTrackerService(StoreMap<String,Integer> countMap)

Method Summary

Modifier and Type	Method and Description
protected String	calcKey(T token, FlowStatus status)
void	clearCount()
void	clearCount(Shift<T> shift)
void	clearCount(T token)
int	count(T token, FlowStatus status) Return the # of times a Token has been notified.
protected boolean	isKeyFor(String key, Shift<T> shift)
protected boolean	isKeyFor(String key, T token)
protected boolean	isKeyFor(String key, T token, FlowStatus status)
int	keepCount(T token, FlowStatus status) Update and return latest count

Methods inherited from class java.lang.Object

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

Field Detail

countMap

protected StoreMap<String,Integer> countMap

Constructor Detail

DefaultTokenNotificationTrackerService

public DefaultTokenNotificationTrackerService()

DefaultTokenNotificationTrackerService

public DefaultTokenNotificationTrackerService(StoreMap<String,Integer> countMap)

Method Detail

calcKey

protected String calcKey(T token,
                         FlowStatus status)

isKeyFor

protected boolean isKeyFor(String key,
                           T token,
                           FlowStatus status)

isKeyFor

protected boolean isKeyFor(String key,
                           T token)

isKeyFor

protected boolean isKeyFor(String key,
                           Shift<T> shift)

keepCount

public int keepCount(T token,
                     FlowStatus status)

Description copied from interface: TokenNotificationTrackerService

Update and return latest count

Specified by:

keepCount in interface TokenNotificationTrackerService<T extends Token<T>>

Parameters:

token - as Token type

status - as FlowStatus

Returns:

count of times Token was notified. 0 or less means none.

count

public int count(T token,
                 FlowStatus status)

Description copied from interface: TokenNotificationTrackerService

Return the # of times a Token has been notified.

Specified by:

count in interface TokenNotificationTrackerService<T extends Token<T>>

Parameters:

token - as Token type

status - as FlowStatus

Returns:

count of times Token was notified. 0 or less means none.

clearCount

public void clearCount(T token)

Specified by:

clearCount in interface TokenNotificationTrackerService<T extends Token<T>>

clearCount

public void clearCount(Shift<T> shift)

Specified by:

clearCount in interface TokenNotificationTrackerService<T extends Token<T>>

clearCount

public void clearCount()

Specified by:

clearCount in interface TokenNotificationTrackerService<T extends Token<T>>