AggregatePart

public abstract class AggregatePart<I, S extends EntityState, B extends ValidatingBuilder<S>, R extends AggregateRoot<I>> extends Aggregate<I, S, B>

A part of a larger aggregate.

Some business logic objects may be big enough. If not all parts of such a business object need to be preserved at the same time as business logic invariants, such an object can be split into several parts.

Each such part would:

  • be a class derived from AggregatePart
  • have the same aggregate ID as other parts belonging to the same business object
  • have own state defined as a Protobuf message
  • managed by a separate repository class derived from AggregateRepository

To access parts of the aggregate, AggregateRoot should be used.

If your business logic cannot be split into parts, it can be modified separately. Consider extending Aggregate instead of several AggregateParts.

Parameters

<I>

the type for IDs of this class of aggregates

<S>

the type of the state held by the aggregate part

<B>

the type of the aggregate part state builder

<R>

the type of the aggregate root

See also

Constructors

Link copied to clipboard
protected void AggregatePart(R root)
Creates a new instance of the aggregate part.

Types

Link copied to clipboard
public enum GenericParameter
Enumeration of generic type parameters of this class.

Inherited properties

Link copied to clipboard
public volatile LifecycleFlags lifecycleFlags
The lifecycle flags of the entity.

Functions

Link copied to clipboard
protected final AggregatePartClass<? extends Object> modelClass()
Obtains the model class.
Link copied to clipboard
protected P partState<P extends EntityState>(Class<P> partStateClass)
Obtains a state of another AggregatePart by its class.
Link copied to clipboard
protected AggregatePartClass<? extends Object> thisClass()
Obtains model class for this aggregate part.

Inherited functions

Link copied to clipboard
public void afterInvoke(HandlerMethod<? extends Object, ? extends Object, ? extends Object, ? extends Object> method)
A callback for a handler method invocation end.
Link copied to clipboard
public final Api at(Level logLevel)
Obtains a new fluent logging API at the given level.
Link copied to clipboard
public void beforeInvoke(HandlerMethod<? extends Object, ? extends Object, ? extends Object, ? extends Object> method)
A callback for a handler method invocation start.
Link copied to clipboard
protected final B builder()
Obtains the instance of the state builder.
Link copied to clipboard
public final boolean changed()
Determines whether the state of this entity or its lifecycle flags have been modified since this entity instance creation.
Link copied to clipboard
protected final List<ConstraintViolation> checkEntityState(S newState)
Verifies the new entity state and returns ConstraintViolations, if any.
Link copied to clipboard
protected void checkNotArchived()
Ensures that the entity is not marked as archived.
Link copied to clipboard
protected void checkNotDeleted()
Ensures that the entity is not marked as deleted.
Link copied to clipboard
protected final void clearRecentHistory()
Clears #recentHistory() recent history.
Link copied to clipboard
protected final S defaultState()
Obtains the default state of the entity.
Link copied to clipboard
protected DispatchOutcome dispatchCommand(CommandEnvelope command)
Obtains a method for the passed command and invokes it.
protected abstract DispatchOutcome dispatchCommand(CommandEnvelope cmd)
Dispatches the passed command to appropriate handler.
Link copied to clipboard
protected void ensureAccessToState()
Prohibits invoking state() method from within an applier method.
Link copied to clipboard
public boolean equals(Object o)
Link copied to clipboard
protected ValueMismatch expectedDefault(Message actual, Message newValue)
Creates ValueMismatch for the case of discovering a non-default value when the default value was expected by a command.
Link copied to clipboard
protected ValueMismatch expectedEmpty(String actual, String newValue)
Creates ValueMismatch for the case of discovering a non-empty value, when an empty string was expected by a command.
Link copied to clipboard
protected ValueMismatch expectedNotDefault(Message expected)
Creates a ValueMismatch for a command that wanted to clear a value, but discovered that the field already has the default value.
protected ValueMismatch expectedNotDefault(Message expected, Message newValue)
Creates a ValueMismatch for a command that wanted to change a field value, but discovered that the field has the default value.
Link copied to clipboard
protected ValueMismatch expectedNotEmpty(String expected)
Creates a ValueMismatch for a command that wanted to clear a string value but discovered that the field is already empty.
Link copied to clipboard
public static EventPlayer forTransactionOf(TransactionalEntity<? extends Object, ? extends Object, ? extends Object> entity)
Creates a transactional EventPlayer for the given entity.
Link copied to clipboard
public final LifecycleFlags getLifecycleFlags()
Obtains the current state of the entity lifecycle flags.
Link copied to clipboard
public int hashCode()
Link copied to clipboard
protected final Iterator<Event> historyBackward()
Creates an iterator of the aggregate event history with reverse traversal.
Link copied to clipboard
protected final boolean historyContains(Predicate<Event> predicate)
Verifies if the aggregate history contains an event which satisfies the passed predicate.
Link copied to clipboard
public I id()
Obtains the identifier of the entity.
Link copied to clipboard
public String idAsString()
Obtains ID of the entity in the string form.
Link copied to clipboard
public boolean isActive()
Verifies if any of the lifecycle attributes is set.
Link copied to clipboard
public final boolean isArchived()
Tests whether the entity is marked as archived.
Link copied to clipboard
public final boolean isDeleted()
Tests whether the entity is marked as deleted.
Link copied to clipboard
public LifecycleFlags lifecycleFlags()
Obtains current lifecycle flags.
Link copied to clipboard
public boolean lifecycleFlagsChanged()
Tells whether lifecycle flags of the entity changed since its initialization.
Link copied to clipboard
protected final String missingTxMessage()
Instructs to modify the state of an aggregate only within an event applier method.
Link copied to clipboard
protected EntityClass<? extends Object> modelClass()
Obtains the model class.
Link copied to clipboard
public Nothing nothing()
Obtains the io.spine.server.model.
Link copied to clipboard
public final BatchDispatchOutcome play(Iterable<Event> events)
Plays the given events against the underlying entity.
public DispatchOutcome play(Event event)
Plays the given event.
Link copied to clipboard
public ImmutableSet<EventClass> producedEvents()
Obtains classes of the events produced by this object.
Link copied to clipboard
public Any producerId()
The object identity packed into Any.
Link copied to clipboard
protected final RecentHistory recentHistory()
Obtains recent history of events of this entity.
Link copied to clipboard
protected void remember(Iterable<Event> events)
Adds events to the recent history.
Link copied to clipboard
protected final void setArchived(boolean archived)
Sets archived} status flag to the passed value.
Link copied to clipboard
protected final void setDeleted(boolean deleted)
Sets deleted} status flag to the passed value.
Link copied to clipboard
protected final void setInitialState(S initialState, Version version)
Sets an initial state for the entity.
Link copied to clipboard
public final S state()
Obtains the state of the entity.
Link copied to clipboard
protected EntityClass<? extends Object> thisClass()
Obtains model class for this entity.
Link copied to clipboard
public String toString()
Link copied to clipboard
protected Transaction<I, ? extends TransactionalEntity<I, S, B>, S, B> tx()
Obtains the transaction used for modifying the entity.
Link copied to clipboard
protected ValueMismatch unexpectedValue(Message expected, Message actual, Message newValue)
Creates ValueMismatch for the case of discovering a value different than by a command.
protected ValueMismatch unexpectedValue(String expected, String actual, String newValue)
Creates ValueMismatch for the case of discovering a value different than expected by a command.
Link copied to clipboard
public Version version()
Obtains the version of the entity.
Link copied to clipboard
protected final int versionNumber()
Obtains the version number of the entity.
Link copied to clipboard
public Timestamp whenModified()
Obtains timestamp of the entity version.