com.lightbend.lagom.javadsl.persistence

Class AggregateEventShards<Event extends AggregateEvent<Event>>

Object

com.lightbend.lagom.javadsl.persistence.AggregateEventShards<Event>

All Implemented Interfaces:

AggregateEventTagger<Event>

public final class AggregateEventShards<Event extends AggregateEvent<Event>>
extends Object
implements AggregateEventTagger<Event>

The base type of PersistentEntity events may return one of these to make the events available for sharded read-side processing.

The tag should be unique among the event types of the service.

The numShards should be stable and never change.

The class name can be used as tag, but note that it is needed to retain the original tag when the class name is changed because the tag is part of the store event data.

Constructor Summary

Constructors

Constructor and Description
AggregateEventShards(Class<Event> eventType, String tag, int numShards)

Method Summary

Modifier and Type	Method and Description
org.pcollections.PSequence<AggregateEventTag<Event>>	allTags()
boolean	equals(Object other)
Class<Event>	eventType()
AggregateEventTag<Event>	forEntityId(String entityId) Get the tag for the given entity ID.
int	hashCode()
int	numShards()
String	tag()
String	toString()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AggregateEventShards

public AggregateEventShards(Class<Event> eventType,
                            String tag,
                            int numShards)

Method Detail

allTags

public org.pcollections.PSequence<AggregateEventTag<Event>> allTags()

Returns:

all the tags that this app will use according to the numShards and the eventType

equals

public boolean equals(Object other)

Overrides:

equals in class Object

eventType

public Class<Event> eventType()

Specified by:

eventType in interface AggregateEventTagger<Event extends AggregateEvent<Event>>

forEntityId

public AggregateEventTag<Event> forEntityId(String entityId)

Get the tag for the given entity ID.

Parameters:

entityId - The entity ID to get the tag for.

Returns:

The tag.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

numShards

public int numShards()

tag

public String tag()

toString

public String toString()

Overrides:

toString in class Object