io.eventuate.tram.sagas.eventsourcingsupport

Class CommandMessageAggregateRepositoryInterceptor

java.lang.Object

io.eventuate.tram.sagas.eventsourcingsupport.CommandMessageAggregateRepositoryInterceptor

All Implemented Interfaces:

io.eventuate.AggregateRepositoryInterceptor

public class CommandMessageAggregateRepositoryInterceptor
extends java.lang.Object
implements io.eventuate.AggregateRepositoryInterceptor

Constructor Summary

Constructors

Constructor and Description
CommandMessageAggregateRepositoryInterceptor(io.eventuate.tram.commands.consumer.CommandMessage commandMessage)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<io.eventuate.UpdateEventsAndOptions>	handleException(io.eventuate.CommandProcessingAggregate aggregate, java.lang.Throwable throwable, java.util.Optional optional)
io.eventuate.UpdateEventsAndOptions	transformUpdate(io.eventuate.CommandProcessingAggregate aggregate, io.eventuate.UpdateEventsAndOptions ueo)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandMessageAggregateRepositoryInterceptor

public CommandMessageAggregateRepositoryInterceptor(io.eventuate.tram.commands.consumer.CommandMessage commandMessage)

Method Detail

transformUpdate

public io.eventuate.UpdateEventsAndOptions transformUpdate(io.eventuate.CommandProcessingAggregate aggregate,
                                                           io.eventuate.UpdateEventsAndOptions ueo)

Specified by:

transformUpdate in interface io.eventuate.AggregateRepositoryInterceptor

handleException

public java.util.Optional<io.eventuate.UpdateEventsAndOptions> handleException(io.eventuate.CommandProcessingAggregate aggregate,
                                                                               java.lang.Throwable throwable,
                                                                               java.util.Optional optional)

Specified by:

handleException in interface io.eventuate.AggregateRepositoryInterceptor