Package org.axonframework.eventhandling.tokenstore

Class GenericTokenEntry<T>

java.lang.Object

org.axonframework.eventhandling.tokenstore.AbstractTokenEntry<T>

org.axonframework.eventhandling.tokenstore.GenericTokenEntry<T>

Type Parameters:

T - The serialized data type of the token

public class GenericTokenEntry<T>
extends AbstractTokenEntry<T>

Generic implementation of a token entry.

Author:

Rene de Waele

Field Summary

Fields inherited from class org.axonframework.eventhandling.tokenstore.AbstractTokenEntry

clock

Constructor Summary

Constructors

Constructor	Description
GenericTokenEntry(TrackingToken token, Serializer serializer, Class<T> contentType, String processorName, int segment)	Initializes a new token entry for given token, process and segment.
GenericTokenEntry(T token, String tokenType, String timestamp, String owner, String processorName, int segment, Class<T> contentType)	Initializes a token entry from existing data.

Method Summary

Modifier and Type	Method	Description
String	getProcessorName()	Returns the name of the process to which this token belongs.
int	getSegment()	Returns the segment index of the process to which this token belongs.
void	updateToken(TrackingToken token, Serializer serializer)	Update this entry with the given token, serializing it using given serializer.

Methods inherited from class org.axonframework.eventhandling.tokenstore.AbstractTokenEntry

claim, getOwner, getSerializedToken, getToken, getTokenType, mayClaim, releaseClaim, timestamp, timestampAsString, updateToken

Methods inherited from class java.lang.Object

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

Constructor Details

GenericTokenEntry

public GenericTokenEntry(TrackingToken token,
 Serializer serializer,
 Class<T> contentType,
 String processorName,
 int segment)

Initializes a new token entry for given token, process and segment. The given serializer can be used to serialize the token before it is stored.

Parameters:

token - The tracking token to store

serializer - The serializer to use when storing a serialized token

contentType - The content type after serialization

processorName - The name of the processor to which this token belongs

segment - The segment of the processor to which this token belongs

GenericTokenEntry

public GenericTokenEntry(T token,
 String tokenType,
 String timestamp,
 String owner,
 String processorName,
 int segment,
 Class<T> contentType)

Initializes a token entry from existing data.

Parameters:

token - the serialized token

tokenType - the serialized type of the token

timestamp - the timestamp of the token

owner - the owner of the token

processorName - The name of the processor to which this token belongs

segment - The segment of the processor to which this token belongs

contentType - The content type after serialization

Method Details

getProcessorName

public String getProcessorName()

Description copied from class: AbstractTokenEntry

Returns the name of the process to which this token belongs.

Specified by:

getProcessorName in class AbstractTokenEntry<T>

Returns:

the process name

getSegment

public int getSegment()

Description copied from class: AbstractTokenEntry

Returns the segment index of the process to which this token belongs.

Specified by:

getSegment in class AbstractTokenEntry<T>

Returns:

the segment index

updateToken

public void updateToken(TrackingToken token,
 Serializer serializer)

Description copied from class: AbstractTokenEntry

Update this entry with the given token, serializing it using given serializer.

Specified by:

updateToken in class AbstractTokenEntry<T>

Parameters:

token - The token to update the entry with

serializer - The serializer to serialize data with