org.axonframework.eventhandling.tokenstore.jpa

Class TokenEntry

java.lang.Object

org.axonframework.eventhandling.tokenstore.AbstractTokenEntry<byte[]>

org.axonframework.eventhandling.tokenstore.jpa.TokenEntry

@Entity
public class TokenEntry
extends AbstractTokenEntry<byte[]>

Implementation of a token entry compatible with JPA that stores its serialized token as a byte array.

Author:

Rene de Waele, Allard Buijze

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TokenEntry.PK Primary key for token entries used by JPA

Field Summary

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

clock

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TokenEntry() Default constructor for JPA
	TokenEntry(String processorName, int segment, TrackingToken token, Serializer serializer) Initializes a new token entry for given token, processorName and segment.

Method Summary

Modifier and Type	Method and 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 Detail

TokenEntry

public TokenEntry(String processorName,
                  int segment,
                  TrackingToken token,
                  Serializer serializer)

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

Parameters:

token - The tracking token to store

processorName - The name of the processor to store this token for

segment - The segment index of the processor

serializer - The serializer to use when storing a serialized token

TokenEntry

protected TokenEntry()

Default constructor for JPA

Method Detail

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<byte[]>

Parameters:

token - The token to update the entry with

serializer - The serializer to serialize data with

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<byte[]>

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<byte[]>

Returns:

the segment index