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() Get all the tags for this shard.
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

eventType

public Class<Event> eventType()

Specified by:

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

tag

public String tag()

numShards

public int numShards()

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.

allTags

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

Get all the tags for this shard.

Returns:

All the tags.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object