A B C D E F G H I L M N O P R S T U V W Z

A

AbstractOrdersAndCustomersIntegrationTest - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests

AbstractOrdersAndCustomersIntegrationTest() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

AbstractParticipantInvocation<Data> - Class in io.eventuate.tram.sagas.simpledsl

AbstractParticipantInvocation(Optional<Predicate<Data>>) - Constructor for class io.eventuate.tram.sagas.simpledsl.AbstractParticipantInvocation

AbstractSagaCommandHandlersBuilder - Interface in io.eventuate.tram.sagas.participant

add(Money) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

add(SagaParticipantStubCommandHandler) - Method in class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

addDestinationsAndResources(Set<DestinationAndResource>) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

addStep(SagaStep<Data>) - Method in class io.eventuate.tram.sagas.simpledsl.SimpleSagaDefinitionBuilder

AggregateRepositoryInterceptorExceptionHandlerBuilder<T extends io.eventuate.CommandProcessingAggregate<T,CT>,CT extends io.eventuate.Command> - Class in io.eventuate.tram.sagas.eventsourcingsupport

AggregateRepositoryInterceptorExceptionHandlerBuilder(Class<Throwable>, BiFunction<T, Throwable, Optional<UpdateEventsAndOptions>>) - Constructor for class io.eventuate.tram.sagas.eventsourcingsupport.AggregateRepositoryInterceptorExceptionHandlerBuilder

andGiven() - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

apply(Data, DomainEventEnvelope<EventClass>) - Method in interface io.eventuate.tram.sagas.orchestration.EventStartingHandler

apply(Data, Reply) - Method in interface io.eventuate.tram.sagas.orchestration.SagaStateMachineAction

apply(Data, DomainEventEnvelope<EventClass>) - Method in interface io.eventuate.tram.sagas.orchestration.SagaStateMachineEventHandler

apply(CommandMessage<C>, PathVariables, Message) - Method in interface io.eventuate.tram.sagas.participant.PostLockFunction

approve - Variable in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy.OrderServiceProxy

approve(CommandMessage<ApproveOrderCommand>) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderCommandHandler

ApproveOrderCommand - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants

ApproveOrderCommand(long) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ApproveOrderCommand

assertCreateOrderSagaCompletedSuccesfully(Order) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

assertCreateOrderSagaRolledBack(Order) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

assertEventReceived(Class<T>, Consumer<T>) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.SagaEventsConsumer

assertSagaData(Consumer<T>) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

B

build() - Method in class io.eventuate.tram.sagas.eventsourcingsupport.AggregateRepositoryInterceptorExceptionHandlerBuilder

build() - Method in class io.eventuate.tram.sagas.eventsourcingsupport.UpdatingOptionsBuilder

build() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

build() - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

build() - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

build() - Method in class io.eventuate.tram.sagas.simpledsl.CommandEndpointBuilder

build() - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

build() - Method in class io.eventuate.tram.sagas.simpledsl.LocalStepBuilder

build() - Method in class io.eventuate.tram.sagas.simpledsl.SimpleSagaDefinitionBuilder

builder() - Static method in class io.eventuate.tram.sagas.orchestration.SagaActions

Builder() - Constructor for class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

C

CancelOrderCommand - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants

CancelOrderCommand() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.CancelOrderCommand

catching(Class<E>, Supplier<Message>) - Method in class io.eventuate.tram.sagas.eventsourcingsupport.UpdatingOptionsBuilder

channelMapping(TramCommandsAndEventsIntegrationData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.CommonIntegrationTestFactory

claimLock(String, String, String) - Method in interface io.eventuate.tram.sagas.common.SagaLockManager

claimLock(String, String, String) - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

command(Command) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

CommandEndpoint<C extends io.eventuate.tram.commands.common.Command> - Class in io.eventuate.tram.sagas.simpledsl

CommandEndpoint(String, Class<C>, Set<Class>) - Constructor for class io.eventuate.tram.sagas.simpledsl.CommandEndpoint

CommandEndpointBuilder<C extends io.eventuate.tram.commands.common.Command> - Class in io.eventuate.tram.sagas.simpledsl

CommandEndpointBuilder(Class<C>) - Constructor for class io.eventuate.tram.sagas.simpledsl.CommandEndpointBuilder

commandHandlerDefinitions() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerCommandHandler

commandHandlerDefinitions() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderCommandHandler

CommandMessageAggregateRepositoryInterceptor - Class in io.eventuate.tram.sagas.eventsourcingsupport

CommandMessageAggregateRepositoryInterceptor(CommandMessage) - Constructor for class io.eventuate.tram.sagas.eventsourcingsupport.CommandMessageAggregateRepositoryInterceptor

CommonIntegrationTestFactory - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests

CommonIntegrationTestFactory() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.CommonIntegrationTestFactory

consumerCommandDispatcher(CustomerCommandHandler, SagaLockManager, SagaCommandDispatcherFactory) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.CustomerFactory

consumerCommandDispatcher(CustomerCommandHandler, SagaLockManager, SagaCommandDispatcherFactory) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.CustomerConfiguration

create(Saga<SagaData>, SagaData) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceFactory

create(Data) - Method in interface io.eventuate.tram.sagas.orchestration.SagaManager

create(Data, Optional<String>) - Method in interface io.eventuate.tram.sagas.orchestration.SagaManager

create(Data, Class, Object) - Method in interface io.eventuate.tram.sagas.orchestration.SagaManager

create(Data) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

create(Data, Class, Object) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

create(Data, Optional<String>) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

createCustomer(String, Money) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerService

createOrder(Customer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

createOrder(OrderDetails) - Static method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

createOrder(OrderDetails) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderService

createOrderSaga(DomainEventPublisher) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

CreateOrderSaga - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

CreateOrderSaga(DomainEventPublisher) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSaga

createOrderSaga(DomainEventPublisher) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

CreateOrderSagaCompletedSuccesfully - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

CreateOrderSagaCompletedSuccesfully() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaCompletedSuccesfully

CreateOrderSagaCompletedSuccesfully(long) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaCompletedSuccesfully

CreateOrderSagaData - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

CreateOrderSagaData() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaData

CreateOrderSagaData(Long, OrderDetails) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaData

CreateOrderSagaData(OrderDetails) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaData

createOrderSagaManager(Saga<CreateOrderSagaData>, SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

createOrderSagaManager(Saga<CreateOrderSagaData>, SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

CreateOrderSagaRolledBack - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

CreateOrderSagaRolledBack() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaRolledBack

CreateOrderSagaRolledBack(long) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaRolledBack

Customer - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain

Customer() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.Customer

Customer(String, Money) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.Customer

CustomerCommandHandler - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service

CustomerCommandHandler(CustomerDao) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerCommandHandler

customerCommandHandler(CustomerDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.CustomerFactory

customerCommandHandler(CustomerDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.CustomerConfiguration

CustomerConfiguration - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers

CustomerConfiguration() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.CustomerConfiguration

CustomerCreditLimitExceededException - Exception in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain

CustomerCreditLimitExceededException() - Constructor for exception io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.CustomerCreditLimitExceededException

CustomerCreditReservationFailed - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service

CustomerCreditReservationFailed() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerCreditReservationFailed

CustomerCreditReserved - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service

CustomerCreditReserved() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerCreditReserved

CustomerDao - Interface in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain

CustomerDaoImpl - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.domain

CustomerDaoImpl() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.domain.CustomerDaoImpl

CustomerDaoImpl - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain

CustomerDaoImpl() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain.CustomerDaoImpl

CustomerFactory - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers

CustomerFactory() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.CustomerFactory

CustomerRepository - Interface in io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain

CustomerService - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service

CustomerService(CustomerDao) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerService

customerService(CustomerDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.CustomerFactory

customerService - Variable in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

customerService(CustomerDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.CustomerConfiguration

CustomerServiceProxy - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy

CustomerServiceProxy() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy.CustomerServiceProxy

D

deserializeSagaData(SerializedSagaData) - Static method in class io.eventuate.tram.sagas.orchestration.SagaDataSerde

DestinationAndResource - Class in io.eventuate.tram.sagas.orchestration

DestinationAndResource(String, String) - Constructor for class io.eventuate.tram.sagas.orchestration.DestinationAndResource

domainEventDispatcher(TramCommandsAndEventsIntegrationData, SagaEventsConsumer, DomainEventDispatcherFactory) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.CommonIntegrationTestFactory

domainEventHandlers() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.SagaEventsConsumer

E

encodeState(SagaExecutionState) - Static method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionStateJsonSerde

EnlistedAggregate - Class in io.eventuate.tram.sagas.orchestration

EnlistedAggregate(Class<Object>, Object) - Constructor for class io.eventuate.tram.sagas.orchestration.EnlistedAggregate

EnlistedAggregatesDao - Class in io.eventuate.tram.sagas.orchestration

EnlistedAggregatesDao(EventuateJdbcStatementExecutor) - Constructor for class io.eventuate.tram.sagas.orchestration.EnlistedAggregatesDao

equals(Object) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

equals(Object) - Method in class io.eventuate.tram.sagas.orchestration.DestinationAndResource

equals(Object) - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregate

EventClassAndAggregateId - Class in io.eventuate.tram.sagas.orchestration

EventClassAndAggregateId(Class<DomainEvent>, Long) - Constructor for class io.eventuate.tram.sagas.orchestration.EventClassAndAggregateId

eventClassAndAggregateId(Data) - Method in class io.eventuate.tram.sagas.orchestration.SagaEventHandler

EventStartingHandler<Data,EventClass extends io.eventuate.tram.events.common.DomainEvent> - Interface in io.eventuate.tram.sagas.orchestration

EventToPublish - Class in io.eventuate.tram.sagas.orchestration

EventToPublish(Class, String, List<DomainEvent>) - Constructor for class io.eventuate.tram.sagas.orchestration.EventToPublish

eventuateCommonInMemoryScriptSupplierForEventuateTramSagas() - Method in class io.eventuate.tram.sagas.spring.inmemory.TramSagaInMemoryConfiguration

EventuateTramSagaCommonConfiguration - Class in io.eventuate.tram.sagas.spring.common

EventuateTramSagaCommonConfiguration() - Constructor for class io.eventuate.tram.sagas.spring.common.EventuateTramSagaCommonConfiguration

EventuateTramSagaCommonFactory - Class in io.eventuate.tram.sagas.micronaut.common

EventuateTramSagaCommonFactory() - Constructor for class io.eventuate.tram.sagas.micronaut.common.EventuateTramSagaCommonFactory

executeStep(Data, SagaExecutionState) - Method in class io.eventuate.tram.sagas.simpledsl.StepToExecute

expect() - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

expectCompletedSuccessfully() - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

expectException(Exception) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

expectRolledBack() - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

F

failureReply() - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

failureReply(Object) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

find(String, String) - Method in interface io.eventuate.tram.sagas.orchestration.SagaInstanceRepository

find(String, String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

findById(long) - Method in interface io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.CustomerDao

findById(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.domain.CustomerDaoImpl

findById(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.domain.OrderDaoImpl

findById(long) - Method in interface io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.OrderDao

findById(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain.CustomerDaoImpl

findById(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain.OrderDaoImpl

findCommandHandler(String, Class<C>) - Method in class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

findEnlistedAggregates(String) - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregatesDao

findExceptionHandler(Throwable) - Method in class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

findSagas(Class, String) - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregatesDao

findTargetMethod(Message) - Method in class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

forChannel(String) - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

forCommand(Class<C>) - Static method in class io.eventuate.tram.sagas.simpledsl.CommandEndpointBuilder

fromChannel(String) - Static method in class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

G

getAction() - Method in class io.eventuate.tram.sagas.orchestration.SagaEventHandler

getAggregateClass() - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregate

getAggregateDestination() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.TramCommandsAndEventsIntegrationData

getAggregateId() - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregate

getAggregateId() - Method in class io.eventuate.tram.sagas.orchestration.EventClassAndAggregateId

getAggregateId() - Method in class io.eventuate.tram.sagas.orchestration.EventToPublish

getAggregateType() - Method in class io.eventuate.tram.sagas.orchestration.EventToPublish

getAmount() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

getChannels() - Method in class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

getChannels() - Method in class io.eventuate.tram.sagas.testing.SagaParticipantChannels

getCommand() - Method in class io.eventuate.tram.sagas.orchestration.PendingSagaCommand

getCommand() - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantParamsAndCommand

getCommandChannel() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.TramCommandsAndEventsIntegrationData

getCommandChannel() - Method in class io.eventuate.tram.sagas.simpledsl.CommandEndpoint

getCommandClass() - Method in class io.eventuate.tram.sagas.simpledsl.CommandEndpoint

getCommandDispatcherId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.TramCommandsAndEventsIntegrationData

getCommands() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

getCorrelationHeaders() - Method in class io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEvent

getCurrentlyExecuting() - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

getCustomerId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

getCustomerId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderDetails

getDeleteFromSagaLockTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

getDeleteFromSagaStashTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

getDestination() - Method in class io.eventuate.tram.sagas.orchestration.DestinationAndResource

getDestination() - Method in class io.eventuate.tram.sagas.orchestration.PendingSagaCommand

getDestination() - Method in class io.eventuate.tram.sagas.testing.MessageWithDestination

getDestinationsAndResources() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

getDomainEvents() - Method in class io.eventuate.tram.sagas.orchestration.EventToPublish

getEventClass() - Method in class io.eventuate.tram.sagas.orchestration.EventClassAndAggregateId

getEventClass() - Method in class io.eventuate.tram.sagas.orchestration.SagaEventHandler

getEventDispatcherId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.TramCommandsAndEventsIntegrationData

getId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.Customer

getId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

getId() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

getInsertIntoSagaInstanceParticipantsSql() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

getInsertIntoSagaInstanceSql() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

getInsertIntoSagaLockTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

getInsertIntoSagaStashTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

getLastRequestId() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

getLocalException() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

getLockTarget() - Method in class io.eventuate.tram.sagas.participant.SagaReplyMessage

getMessage() - Method in class io.eventuate.tram.sagas.common.StashedMessage

getMessage() - Method in class io.eventuate.tram.sagas.testing.MessageWithDestination

getOrderDetails() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaData

getOrderDetails() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSagaData

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaCompletedSuccesfully

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaData

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaRolledBack

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSagaData

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ApproveOrderCommand

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

getOrderId() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.RejectOrderCommand

getOrderTotal() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

getOrderTotal() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderDetails

getParams() - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantParamsAndCommand

getPostLock() - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandler

getPreLock() - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandler

getReplyClasses() - Method in class io.eventuate.tram.sagas.simpledsl.CommandEndpoint

getReplyHandler(Message, boolean) - Method in class io.eventuate.tram.sagas.simpledsl.LocalStep

getReplyHandler(Message, boolean) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationStep

getReplyHandler(Message, boolean) - Method in interface io.eventuate.tram.sagas.simpledsl.SagaStep

getResource() - Method in class io.eventuate.tram.sagas.orchestration.DestinationAndResource

getResource() - Method in class io.eventuate.tram.sagas.orchestration.PendingSagaCommand

getSagaData() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceData

getSagaDataJSON() - Method in class io.eventuate.tram.sagas.orchestration.SerializedSagaData

getSagaDataType() - Method in class io.eventuate.tram.sagas.orchestration.SerializedSagaData

getSagaDefinition() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSaga

getSagaDefinition() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSaga

getSagaDefinition() - Method in interface io.eventuate.tram.sagas.orchestration.Saga

getSagaEventsChannel() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.TramCommandsAndEventsIntegrationData

getSagaId() - Method in class io.eventuate.tram.sagas.common.StashedMessage

getSagaId() - Method in class io.eventuate.tram.sagas.orchestration.SagaTypeAndId

getSagaInstance() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceData

getSagaType() - Method in class io.eventuate.tram.sagas.common.StashedMessage

getSagaType() - Method in interface io.eventuate.tram.sagas.orchestration.Saga

getSagaType() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

getSagaType() - Method in class io.eventuate.tram.sagas.orchestration.SagaTypeAndId

getSelectFromSagaInstanceParticipantsSql() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

getSelectFromSagaInstanceSql() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

getSelectFromSagaLockTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

getSelectFromSagaStashTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

getSerializedSagaData() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

getState() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

getStateName() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

getTarget() - Method in class io.eventuate.tram.sagas.common.LockTarget

getTarget() - Method in exception io.eventuate.tram.sagas.common.StashMessageRequiredException

getUpdatedSagaData() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

getUpdatedState() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

getUpdateSagaInstanceSql() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

getUpdateSagaLockTableSql() - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

given() - Static method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

H

handleException(CommandProcessingAggregate, Throwable, Optional) - Method in class io.eventuate.tram.sagas.eventsourcingsupport.CommandMessageAggregateRepositoryInterceptor

handleMessage(Message) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

handleReply(String, Data, Message) - Method in interface io.eventuate.tram.sagas.orchestration.SagaDefinition

handleReply(String, Data, Message) - Method in class io.eventuate.tram.sagas.simpledsl.SimpleSagaDefinition

handles(Message) - Method in class io.eventuate.tram.sagas.testing.commandhandling.SagaParticipantStubCommandHandler

handles(String, Class<C>) - Method in class io.eventuate.tram.sagas.testing.commandhandling.SagaParticipantStubCommandHandler

hasAction(Data) - Method in class io.eventuate.tram.sagas.simpledsl.LocalStep

hasAction(Data) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationStep

hasAction(Data) - Method in interface io.eventuate.tram.sagas.simpledsl.SagaStep

hasCompensation(Data) - Method in class io.eventuate.tram.sagas.simpledsl.LocalStep

hasCompensation(Data) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationStep

hasCompensation(Data) - Method in interface io.eventuate.tram.sagas.simpledsl.SagaStep

hashCode() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

hashCode() - Method in class io.eventuate.tram.sagas.orchestration.DestinationAndResource

hashCode() - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregate

hasLockTarget() - Method in class io.eventuate.tram.sagas.participant.SagaReplyMessage

I

init() - Method in class io.eventuate.tram.sagas.micronaut.orchestration.SagaManagerImplInitializer

init() - Method in class io.eventuate.tram.sagas.micronaut.testing.SagaParticipantStubManagerInitializer

initialize() - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

invoke(CommandHandler, CommandMessage, Map<String, String>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandDispatcher

invokeLocal(Consumer<Data>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

invokeMethod(CommandMessage, Map<String, String>) - Method in class io.eventuate.tram.sagas.testing.commandhandling.SagaParticipantStubCommandHandler

invokeParticipant(Function<Data, CommandWithDestination>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

invokeParticipant(Predicate<Data>, Function<Data, CommandWithDestination>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

invokeParticipant(CommandEndpoint<C>, Function<Data, C>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

invokeParticipant(Predicate<Data>, CommandEndpoint<C>, Function<Data, C>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

InvokeParticipantStepBuilder<Data> - Class in io.eventuate.tram.sagas.simpledsl

InvokeParticipantStepBuilder(SimpleSagaDefinitionBuilder<Data>) - Constructor for class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain - package io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain

io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain - package io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain

io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service - package io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service

io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers - package io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers

io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.domain - package io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.domain

io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders - package io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders

io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.domain - package io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.domain

io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests - package io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests

io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain - package io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain

io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.cancelorder - package io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.cancelorder

io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder - package io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants - package io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants

io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy - package io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy

io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service - package io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service

io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers - package io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers

io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain - package io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain

io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders - package io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders

io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain - package io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain

io.eventuate.tram.sagas.common - package io.eventuate.tram.sagas.common

io.eventuate.tram.sagas.eventsourcingsupport - package io.eventuate.tram.sagas.eventsourcingsupport

io.eventuate.tram.sagas.micronaut.common - package io.eventuate.tram.sagas.micronaut.common

io.eventuate.tram.sagas.micronaut.orchestration - package io.eventuate.tram.sagas.micronaut.orchestration

io.eventuate.tram.sagas.micronaut.participant - package io.eventuate.tram.sagas.micronaut.participant

io.eventuate.tram.sagas.micronaut.testing - package io.eventuate.tram.sagas.micronaut.testing

io.eventuate.tram.sagas.orchestration - package io.eventuate.tram.sagas.orchestration

io.eventuate.tram.sagas.participant - package io.eventuate.tram.sagas.participant

io.eventuate.tram.sagas.simpledsl - package io.eventuate.tram.sagas.simpledsl

io.eventuate.tram.sagas.spring.common - package io.eventuate.tram.sagas.spring.common

io.eventuate.tram.sagas.spring.inmemory - package io.eventuate.tram.sagas.spring.inmemory

io.eventuate.tram.sagas.spring.orchestration - package io.eventuate.tram.sagas.spring.orchestration

io.eventuate.tram.sagas.spring.participant - package io.eventuate.tram.sagas.spring.participant

io.eventuate.tram.sagas.spring.testing - package io.eventuate.tram.sagas.spring.testing

io.eventuate.tram.sagas.testing - package io.eventuate.tram.sagas.testing

io.eventuate.tram.sagas.testing.commandhandling - package io.eventuate.tram.sagas.testing.commandhandling

isCompensating() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

isCompensating() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

isCompensating() - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

isEmpty() - Method in class io.eventuate.tram.sagas.simpledsl.StepToExecute

isEndState() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

isEndState() - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

isEndState() - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

isFor(String, long, String) - Method in class io.eventuate.tram.sagas.orchestration.EventClassAndAggregateId

isGreaterThanOrEqual(Money) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

isInvocable(Data) - Method in class io.eventuate.tram.sagas.simpledsl.AbstractParticipantInvocation

isInvocable(Data) - Method in interface io.eventuate.tram.sagas.simpledsl.ParticipantInvocation

isLocal() - Method in class io.eventuate.tram.sagas.orchestration.SagaActions

isSuccessfulReply(boolean, Message) - Method in class io.eventuate.tram.sagas.simpledsl.LocalStep

isSuccessfulReply(Message) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantEndpointInvocationImpl

isSuccessfulReply(Message) - Method in interface io.eventuate.tram.sagas.simpledsl.ParticipantInvocation

isSuccessfulReply(Message) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationImpl

isSuccessfulReply(boolean, Message) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationStep

isSuccessfulReply(boolean, Message) - Method in interface io.eventuate.tram.sagas.simpledsl.SagaStep

L

localCreateOrder(OrderDetails) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderService

localCreateOrderSaga(DomainEventPublisher, OrderDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

LocalCreateOrderSaga - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

LocalCreateOrderSaga(DomainEventPublisher, OrderDao) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSaga

localCreateOrderSaga(DomainEventPublisher, OrderDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

LocalCreateOrderSagaData - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder

LocalCreateOrderSagaData() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSagaData

LocalCreateOrderSagaData(OrderDetails) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSagaData

localCreateOrderSagaManager(Saga<LocalCreateOrderSagaData>, SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

localCreateOrderSagaManager(Saga<LocalCreateOrderSagaData>, SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

LocalStep<Data> - Class in io.eventuate.tram.sagas.simpledsl

LocalStep(Consumer<Data>, Optional<Consumer<Data>>) - Constructor for class io.eventuate.tram.sagas.simpledsl.LocalStep

LocalStepBuilder<Data> - Class in io.eventuate.tram.sagas.simpledsl

LocalStepBuilder(SimpleSagaDefinitionBuilder<Data>, Consumer<Data>) - Constructor for class io.eventuate.tram.sagas.simpledsl.LocalStepBuilder

LockTarget - Class in io.eventuate.tram.sagas.common

LockTarget(Class, Object) - Constructor for class io.eventuate.tram.sagas.common.LockTarget

LockTarget(String, String) - Constructor for class io.eventuate.tram.sagas.common.LockTarget

LockTarget(String) - Constructor for class io.eventuate.tram.sagas.common.LockTarget

M

make(Class<DomainEvent>, Function<Data, Long>, SagaStateMachineAction<Data, DomainEventEnvelope<DomainEvent>>) - Static method in class io.eventuate.tram.sagas.orchestration.SagaEventHandler

make(Saga<SagaData>) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerFactory

make(String, CommandHandlers) - Method in class io.eventuate.tram.sagas.participant.SagaCommandDispatcherFactory

makeCommandToSend(Data) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantEndpointInvocationImpl

makeCommandToSend(Data) - Method in interface io.eventuate.tram.sagas.simpledsl.ParticipantInvocation

makeCommandToSend(Data) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationImpl

makeEndState() - Static method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

makeLocalOutcome(Optional<RuntimeException>) - Static method in class io.eventuate.tram.sagas.simpledsl.StepOutcome

makeRemoteStepOutcome(List<CommandWithDestination>) - Static method in class io.eventuate.tram.sagas.simpledsl.StepOutcome

makeStepOutcome(Data, boolean) - Method in class io.eventuate.tram.sagas.simpledsl.LocalStep

makeStepOutcome(Data, boolean) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationStep

makeStepOutcome(Data, boolean) - Method in interface io.eventuate.tram.sagas.simpledsl.SagaStep

messageHandler(Message) - Method in class io.eventuate.tram.sagas.participant.SagaCommandDispatcher

messageHandler(Message) - Method in class io.eventuate.tram.sagas.testing.commandhandling.UnhandledMessageTrackingCommandDispatcher

MessageWithDestination - Class in io.eventuate.tram.sagas.testing

MessageWithDestination(String, Message) - Constructor for class io.eventuate.tram.sagas.testing.MessageWithDestination

Money - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain

Money() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

Money(int) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

Money(String) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

Money(BigDecimal) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

N

nextState(int) - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

noteCreditReservationFailed() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

noteCreditReserved() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

noteNewCommandHandler(SagaParticipantStubCommandHandler<C>) - Method in class io.eventuate.tram.sagas.testing.commandhandling.UnhandledMessageTrackingCommandDispatcher

O

onMessage(Class<C>, Function<CommandMessage<C>, Message>) - Method in interface io.eventuate.tram.sagas.participant.AbstractSagaCommandHandlersBuilder

onMessage(Class<C>, Consumer<CommandMessage<C>>) - Method in interface io.eventuate.tram.sagas.participant.AbstractSagaCommandHandlersBuilder

onMessage(Class<C>, Function<CommandMessage<C>, Message>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

onMessage(Class<C>, Consumer<CommandMessage<C>>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

onMessage(Class<C>, Function<CommandMessage<C>, Message>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

onMessage(Class<C>, Consumer<CommandMessage<C>>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

onMessageReturningMessages(Class<C>, Function<CommandMessage<C>, List<Message>>) - Method in interface io.eventuate.tram.sagas.participant.AbstractSagaCommandHandlersBuilder

onMessageReturningMessages(Class<C>, Function<CommandMessage<C>, List<Message>>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

onMessageReturningMessages(Class<C>, Function<CommandMessage<C>, List<Message>>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

onMessageReturningOptionalMessage(Class<C>, Function<CommandMessage<C>, Optional<Message>>) - Method in interface io.eventuate.tram.sagas.participant.AbstractSagaCommandHandlersBuilder

onMessageReturningOptionalMessage(Class<C>, Function<CommandMessage<C>, Optional<Message>>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

onMessageReturningOptionalMessage(Class<C>, Function<CommandMessage<C>, Optional<Message>>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

onReply(Class<T>, BiConsumer<Data, T>) - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

onSagaCompletedSuccessfully(String, CreateOrderSagaData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSaga

onSagaCompletedSuccessfully(String, LocalCreateOrderSagaData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSaga

onSagaCompletedSuccessfully(String, Data) - Method in interface io.eventuate.tram.sagas.orchestration.Saga

onSagaRolledBack(String, CreateOrderSagaData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSaga

onSagaRolledBack(String, LocalCreateOrderSagaData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSaga

onSagaRolledBack(String, Data) - Method in interface io.eventuate.tram.sagas.orchestration.Saga

onStarting(String, Data) - Method in interface io.eventuate.tram.sagas.orchestration.Saga

Order - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain

Order() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

Order(OrderDetails) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.Order

orderCommandDispatcher(OrderCommandHandler, SagaCommandDispatcherFactory) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

orderCommandDispatcher(OrderCommandHandler, SagaCommandDispatcherFactory) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

orderCommandHandler(OrderDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

OrderCommandHandler - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service

OrderCommandHandler(OrderDao) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderCommandHandler

orderCommandHandler(OrderDao) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

OrderConfiguration - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders

OrderConfiguration() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

OrderDao - Interface in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain

OrderDaoImpl - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.domain

OrderDaoImpl() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.domain.OrderDaoImpl

OrderDaoImpl - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain

OrderDaoImpl() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain.OrderDaoImpl

OrderDetails - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service

OrderDetails() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderDetails

OrderDetails(Long, Money) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderDetails

OrderFactory - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders

OrderFactory() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

OrderRepository - Interface in io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain

orderService(SagaManager<CreateOrderSagaData>, SagaManager<LocalCreateOrderSagaData>, OrderDao, EventuateTransactionTemplate, SagaInstanceFactory, LocalCreateOrderSaga) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.OrderFactory

orderService - Variable in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

OrderService - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service

OrderService(SagaManager<CreateOrderSagaData>, OrderDao, EventuateTransactionTemplate, SagaInstanceFactory, LocalCreateOrderSaga) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderService

orderService(SagaManager<CreateOrderSagaData>, SagaManager<LocalCreateOrderSagaData>, OrderDao, EventuateTransactionTemplate, SagaInstanceFactory, LocalCreateOrderSaga) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.OrderConfiguration

OrderServiceProxy - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy

OrderServiceProxy() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy.OrderServiceProxy

OrderState - Enum in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain

P

ParticipantEndpointInvocationImpl<Data,C extends io.eventuate.tram.commands.common.Command> - Class in io.eventuate.tram.sagas.simpledsl

ParticipantEndpointInvocationImpl(Optional<Predicate<Data>>, CommandEndpoint<C>, Function<Data, C>) - Constructor for class io.eventuate.tram.sagas.simpledsl.ParticipantEndpointInvocationImpl

ParticipantInvocation<Data> - Interface in io.eventuate.tram.sagas.simpledsl

ParticipantInvocationBuilder - Class in io.eventuate.tram.sagas.simpledsl

ParticipantInvocationBuilder(String, String) - Constructor for class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationBuilder

ParticipantInvocationImpl<Data,C extends io.eventuate.tram.commands.common.Command> - Class in io.eventuate.tram.sagas.simpledsl

ParticipantInvocationImpl(Optional<Predicate<Data>>, Function<Data, CommandWithDestination>) - Constructor for class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationImpl

ParticipantInvocationStep<Data> - Class in io.eventuate.tram.sagas.simpledsl

ParticipantInvocationStep(Optional<ParticipantInvocation<Data>>, Optional<ParticipantInvocation<Data>>, Map<String, BiConsumer<Data, Object>>, Map<String, BiConsumer<Data, Object>>) - Constructor for class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationStep

ParticipantParamsAndCommand<C extends io.eventuate.tram.commands.common.Command> - Class in io.eventuate.tram.sagas.simpledsl

ParticipantParamsAndCommand(Map<String, String>, C) - Constructor for class io.eventuate.tram.sagas.simpledsl.ParticipantParamsAndCommand

PendingSagaCommand - Class in io.eventuate.tram.sagas.orchestration

PendingSagaCommand(String, String, Command) - Constructor for class io.eventuate.tram.sagas.orchestration.PendingSagaCommand

PostLockFunction<C> - Interface in io.eventuate.tram.sagas.participant

R

ReconfigurableCommandHandlers - Class in io.eventuate.tram.sagas.testing.commandhandling

ReconfigurableCommandHandlers(Set<String>) - Constructor for class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

reject(CreateOrderSagaData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSaga

reject(LocalCreateOrderSagaData) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSaga

reject - Variable in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy.OrderServiceProxy

reject(CommandMessage<RejectOrderCommand>) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.OrderCommandHandler

RejectOrderCommand - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service

RejectOrderCommand(long) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.RejectOrderCommand

ReleaseCreditCommand - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.cancelorder

ReleaseCreditCommand() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.cancelorder.ReleaseCreditCommand

REPLY_LOCKED - Static variable in class io.eventuate.tram.sagas.common.SagaReplyHeaders

REPLY_SAGA_ID - Static variable in class io.eventuate.tram.sagas.common.SagaReplyHeaders

REPLY_SAGA_TYPE - Static variable in class io.eventuate.tram.sagas.common.SagaReplyHeaders

replyingTo(CommandMessage<T>) - Static method in class io.eventuate.tram.sagas.eventsourcingsupport.UpdatingOptionsBuilder

replyWith(Function<CommandMessage<C>, Message>) - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager.SagaParticipantStubManagerHelper

replyWithFailure() - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager.SagaParticipantStubManagerHelper

replyWithSuccess() - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager.SagaParticipantStubManagerHelper

reserveCredit(Long, Money) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.Customer

reserveCredit(CommandMessage<ReserveCreditCommand>) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service.CustomerCommandHandler

reserveCredit - Variable in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.proxy.CustomerServiceProxy

ReserveCreditCommand - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants

ReserveCreditCommand() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

ReserveCreditCommand(Long, Long, Money) - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

reset() - Method in class io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

reset() - Method in class io.eventuate.tram.sagas.testing.commandhandling.UnhandledMessageTrackingCommandDispatcher

reset() - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

ResultCreditResult - Interface in io.eventuate.examples.tram.sagas.ordersandcustomers.customers.service

S

Saga<Data> - Interface in io.eventuate.tram.sagas.orchestration

saga(Saga<T>, T) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

SAGA_ID - Static variable in class io.eventuate.tram.sagas.common.SagaCommandHeaders

SAGA_ID - Static variable in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

SAGA_TYPE - Static variable in class io.eventuate.tram.sagas.common.SagaCommandHeaders

SagaActions<Data> - Class in io.eventuate.tram.sagas.orchestration

SagaActions(List<CommandWithDestination>, Optional<Data>, Optional<String>, boolean, boolean, boolean, Optional<RuntimeException>) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaActions

SagaActions.Builder<Data> - Class in io.eventuate.tram.sagas.orchestration

SagaCommandDispatcher - Class in io.eventuate.tram.sagas.participant

SagaCommandDispatcher(String, CommandHandlers, MessageConsumer, MessageProducer, SagaLockManager) - Constructor for class io.eventuate.tram.sagas.participant.SagaCommandDispatcher

sagaCommandDispatcherFactory(MessageConsumer, MessageProducer, SagaLockManager) - Method in class io.eventuate.tram.sagas.micronaut.participant.SagaParticipantFactory

SagaCommandDispatcherFactory - Class in io.eventuate.tram.sagas.participant

SagaCommandDispatcherFactory(MessageConsumer, MessageProducer, SagaLockManager) - Constructor for class io.eventuate.tram.sagas.participant.SagaCommandDispatcherFactory

sagaCommandDispatcherFactory(MessageConsumer, MessageProducer, SagaLockManager) - Method in class io.eventuate.tram.sagas.spring.participant.SagaParticipantConfiguration

SagaCommandHandler - Class in io.eventuate.tram.sagas.participant

SagaCommandHandler(String, String, Class<C>, BiFunction<CommandMessage<C>, PathVariables, List<Message>>) - Constructor for class io.eventuate.tram.sagas.participant.SagaCommandHandler

SagaCommandHandler(String, Class<C>, Function<CommandMessage<C>, List<Message>>) - Constructor for class io.eventuate.tram.sagas.participant.SagaCommandHandler

SagaCommandHandlerBuilder<C> - Class in io.eventuate.tram.sagas.participant

SagaCommandHandlerBuilder(SagaCommandHandlersBuilder, SagaCommandHandler) - Constructor for class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

SagaCommandHandlersBuilder - Class in io.eventuate.tram.sagas.participant

SagaCommandHandlersBuilder() - Constructor for class io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

SagaCommandHeaders - Class in io.eventuate.tram.sagas.common

SagaCommandHeaders() - Constructor for class io.eventuate.tram.sagas.common.SagaCommandHeaders

sagaCommandProducer(CommandProducer) - Method in class io.eventuate.tram.sagas.micronaut.orchestration.SagaOrchestratorFactory

SagaCommandProducer - Class in io.eventuate.tram.sagas.orchestration

SagaCommandProducer(CommandProducer) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaCommandProducer

sagaCommandProducer(CommandProducer) - Method in class io.eventuate.tram.sagas.spring.orchestration.SagaOrchestratorConfiguration

SagaCompletedForAggregateEvent - Class in io.eventuate.tram.sagas.orchestration

SagaCompletedForAggregateEvent(String) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaCompletedForAggregateEvent

SagaDataSerde - Class in io.eventuate.tram.sagas.orchestration

SagaDataSerde() - Constructor for class io.eventuate.tram.sagas.orchestration.SagaDataSerde

SagaDefinition<Data> - Interface in io.eventuate.tram.sagas.orchestration

SagaEndpointInvocation - Class in io.eventuate.tram.sagas.simpledsl

SagaEndpointInvocation() - Constructor for class io.eventuate.tram.sagas.simpledsl.SagaEndpointInvocation

SagaEventHandler<Data> - Class in io.eventuate.tram.sagas.orchestration

SagaEventHandler(Class<DomainEvent>, Function<Data, Long>, SagaStateMachineAction<Data, DomainEventEnvelope<DomainEvent>>) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaEventHandler

sagaEventsConsumer() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.CommonIntegrationTestFactory

SagaEventsConsumer - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests

SagaEventsConsumer() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.SagaEventsConsumer

SagaExecutionState - Class in io.eventuate.tram.sagas.simpledsl

SagaExecutionState() - Constructor for class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

SagaExecutionState(int, boolean) - Constructor for class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

SagaExecutionStateJsonSerde - Class in io.eventuate.tram.sagas.simpledsl

SagaExecutionStateJsonSerde() - Constructor for class io.eventuate.tram.sagas.simpledsl.SagaExecutionStateJsonSerde

SagaInstance - Class in io.eventuate.tram.sagas.orchestration

SagaInstance(String, String, String, String, SerializedSagaData, Set<DestinationAndResource>) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaInstance

SagaInstanceData<Data> - Class in io.eventuate.tram.sagas.orchestration

SagaInstanceData(SagaInstance, Data) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaInstanceData

sagaInstanceFactory(SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Method in class io.eventuate.tram.sagas.micronaut.orchestration.SagaOrchestratorFactory

SagaInstanceFactory - Class in io.eventuate.tram.sagas.orchestration

SagaInstanceFactory(SagaManagerFactory) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaInstanceFactory

sagaInstanceFactory(SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Method in class io.eventuate.tram.sagas.spring.orchestration.SagaOrchestratorConfiguration

sagaInstanceRepository(EventuateJdbcStatementExecutor, IdGenerator, EventuateSchema) - Method in class io.eventuate.tram.sagas.micronaut.orchestration.SagaOrchestratorFactory

SagaInstanceRepository - Interface in io.eventuate.tram.sagas.orchestration

sagaInstanceRepository(EventuateJdbcStatementExecutor, IdGenerator, EventuateSchema) - Method in class io.eventuate.tram.sagas.spring.orchestration.SagaOrchestratorConfiguration

SagaInstanceRepositoryJdbc - Class in io.eventuate.tram.sagas.orchestration

SagaInstanceRepositoryJdbc(EventuateJdbcStatementExecutor, IdGenerator, EventuateSchema) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

SagaLockManager - Interface in io.eventuate.tram.sagas.common

sagaLockManager(EventuateJdbcStatementExecutor, EventuateSchema) - Method in class io.eventuate.tram.sagas.micronaut.common.EventuateTramSagaCommonFactory

sagaLockManager(EventuateJdbcStatementExecutor, EventuateSchema) - Method in class io.eventuate.tram.sagas.spring.common.EventuateTramSagaCommonConfiguration

SagaLockManagerImpl - Class in io.eventuate.tram.sagas.common

SagaLockManagerImpl(EventuateJdbcStatementExecutor, EventuateSchema) - Constructor for class io.eventuate.tram.sagas.common.SagaLockManagerImpl

SagaManager<Data> - Interface in io.eventuate.tram.sagas.orchestration

SagaManagerFactory - Class in io.eventuate.tram.sagas.orchestration

SagaManagerFactory(SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaManagerFactory

SagaManagerImpl<Data> - Class in io.eventuate.tram.sagas.orchestration

SagaManagerImpl(Saga<Data>, SagaInstanceRepository, CommandProducer, MessageConsumer, SagaLockManager, SagaCommandProducer) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

SagaManagerImplInitializer - Class in io.eventuate.tram.sagas.micronaut.orchestration

SagaManagerImplInitializer() - Constructor for class io.eventuate.tram.sagas.micronaut.orchestration.SagaManagerImplInitializer

SagaOrchestratorConfiguration - Class in io.eventuate.tram.sagas.spring.orchestration

SagaOrchestratorConfiguration() - Constructor for class io.eventuate.tram.sagas.spring.orchestration.SagaOrchestratorConfiguration

SagaOrchestratorFactory - Class in io.eventuate.tram.sagas.micronaut.orchestration

SagaOrchestratorFactory() - Constructor for class io.eventuate.tram.sagas.micronaut.orchestration.SagaOrchestratorFactory

SagaParticipantChannels - Class in io.eventuate.tram.sagas.testing

SagaParticipantChannels(String...) - Constructor for class io.eventuate.tram.sagas.testing.SagaParticipantChannels

SagaParticipantConfiguration - Class in io.eventuate.tram.sagas.spring.participant

SagaParticipantConfiguration() - Constructor for class io.eventuate.tram.sagas.spring.participant.SagaParticipantConfiguration

SagaParticipantFactory - Class in io.eventuate.tram.sagas.micronaut.participant

SagaParticipantFactory() - Constructor for class io.eventuate.tram.sagas.micronaut.participant.SagaParticipantFactory

SagaParticipantStubCommandHandler<C> - Class in io.eventuate.tram.sagas.testing.commandhandling

SagaParticipantStubCommandHandler(String, Class<C>, Predicate<Message>, Function<CommandMessage<C>, Message>) - Constructor for class io.eventuate.tram.sagas.testing.commandhandling.SagaParticipantStubCommandHandler

sagaParticipantStubManager(SagaParticipantChannels, MessageConsumer, MessageProducer) - Method in class io.eventuate.tram.sagas.micronaut.testing.SagaParticipantStubManagerFactory

sagaParticipantStubManager(SagaParticipantChannels, MessageConsumer, MessageProducer) - Method in class io.eventuate.tram.sagas.spring.testing.SagaParticipantStubManagerConfiguration

SagaParticipantStubManager - Class in io.eventuate.tram.sagas.testing

Defines a DSL for configuring stubbed saga participants (more generally, recipients of command messages) that response to command messages.

SagaParticipantStubManager(SagaParticipantChannels, MessageConsumer, MessageProducer) - Constructor for class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

SagaParticipantStubManager.SagaParticipantStubManagerHelper<C> - Class in io.eventuate.tram.sagas.testing

SagaParticipantStubManagerConfiguration - Class in io.eventuate.tram.sagas.spring.testing

SagaParticipantStubManagerConfiguration() - Constructor for class io.eventuate.tram.sagas.spring.testing.SagaParticipantStubManagerConfiguration

SagaParticipantStubManagerFactory - Class in io.eventuate.tram.sagas.micronaut.testing

SagaParticipantStubManagerFactory() - Constructor for class io.eventuate.tram.sagas.micronaut.testing.SagaParticipantStubManagerFactory

SagaParticipantStubManagerHelper(SagaParticipantStubManager, Class<C>, Predicate<Message>) - Constructor for class io.eventuate.tram.sagas.testing.SagaParticipantStubManager.SagaParticipantStubManagerHelper

SagaParticipantStubManagerInitializer - Class in io.eventuate.tram.sagas.micronaut.testing

SagaParticipantStubManagerInitializer() - Constructor for class io.eventuate.tram.sagas.micronaut.testing.SagaParticipantStubManagerInitializer

SagaReplyHeaders - Class in io.eventuate.tram.sagas.common

SagaReplyHeaders() - Constructor for class io.eventuate.tram.sagas.common.SagaReplyHeaders

SagaReplyMessage - Class in io.eventuate.tram.sagas.participant

SagaReplyMessage(String, Map<String, String>, Optional<LockTarget>) - Constructor for class io.eventuate.tram.sagas.participant.SagaReplyMessage

SagaReplyMessageBuilder - Class in io.eventuate.tram.sagas.participant

SagaReplyMessageBuilder(LockTarget) - Constructor for class io.eventuate.tram.sagas.participant.SagaReplyMessageBuilder

SagaReplyRequestedEvent - Class in io.eventuate.tram.sagas.eventsourcingsupport

SagaReplyRequestedEvent(Map<String, String>) - Constructor for class io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEvent

SagaReplyRequestedEventSubscriber - Class in io.eventuate.tram.sagas.eventsourcingsupport

SagaReplyRequestedEventSubscriber(String, Set<String>) - Constructor for class io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEventSubscriber

SagaStateMachineAction<Data,Reply> - Interface in io.eventuate.tram.sagas.orchestration

SagaStateMachineEventHandler<Data,EventClass extends io.eventuate.tram.events.common.DomainEvent> - Interface in io.eventuate.tram.sagas.orchestration

SagaStep<Data> - Interface in io.eventuate.tram.sagas.simpledsl

SagaTypeAndId - Class in io.eventuate.tram.sagas.orchestration

SagaTypeAndId(String, String) - Constructor for class io.eventuate.tram.sagas.orchestration.SagaTypeAndId

SagaUnitTestSupport<T> - Class in io.eventuate.tram.sagas.testing

Provides a DSL for writing unit tests for saga orchestrators

SagaUnitTestSupport() - Constructor for class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

SagaUnlockCommand - Class in io.eventuate.tram.sagas.common

SagaUnlockCommand() - Constructor for class io.eventuate.tram.sagas.common.SagaUnlockCommand

save(Customer) - Method in interface io.eventuate.examples.tram.sagas.ordersandcustomers.customers.domain.CustomerDao

save(Customer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.customers.domain.CustomerDaoImpl

save(Order) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.orders.domain.OrderDaoImpl

save(Order) - Method in interface io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.OrderDao

save(Customer) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.customers.domain.CustomerDaoImpl

save(Order) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.spring.orders.domain.OrderDaoImpl

save(String, Set<EnlistedAggregate>) - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregatesDao

save(SagaInstance) - Method in interface io.eventuate.tram.sagas.orchestration.SagaInstanceRepository

save(SagaInstance) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

sendCommand(String, String, String, String, Command, String) - Method in class io.eventuate.tram.sagas.orchestration.SagaCommandProducer

sendCommands(String, String, List<CommandWithDestination>, String) - Method in class io.eventuate.tram.sagas.orchestration.SagaCommandProducer

sendReply(DispatchedEvent<Event>) - Method in class io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEventSubscriber

SerializedSagaData - Class in io.eventuate.tram.sagas.orchestration

SerializedSagaData(String, String) - Constructor for class io.eventuate.tram.sagas.orchestration.SerializedSagaData

serializeSagaData(Data) - Static method in class io.eventuate.tram.sagas.orchestration.SagaDataSerde

setAmount(BigDecimal) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

setCommandProducer(CommandProducer) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

setCompensating(Boolean) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setCompensating(boolean) - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

setCorrelationHeaders(Map<String, String>) - Method in class io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEvent

setCurrentlyExecuting(int) - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

setCustomerId(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

setEndState(Boolean) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setEndState(boolean) - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

setId(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setInsertIntoSagaInstanceParticipantsSql(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

setInsertIntoSagaInstanceSql(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

setLastRequestId(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setMessageConsumer(MessageConsumer) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

setOrderId(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaCompletedSuccesfully

setOrderId(Long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaData

setOrderId(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.CreateOrderSagaRolledBack

setOrderId(Long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.createorder.LocalCreateOrderSagaData

setOrderId(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ApproveOrderCommand

setOrderId(Long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

setOrderId(long) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.service.RejectOrderCommand

setOrderTotal(Money) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.orders.sagas.participants.ReserveCreditCommand

setPostLock(PostLockFunction) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandler

setPreLock(BiFunction<CommandMessage, PathVariables, LockTarget>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandler

setSagaCommandProducer(SagaCommandProducer) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

setSagaInstanceRepository(SagaInstanceRepository) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

setSagaLockManager(SagaLockManager) - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

setSagaType(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setSelectFromSagaInstanceParticipantsSql(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

setSelectFromSagaInstanceSql(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

setSerializedSagaData(SerializedSagaData) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setStateName(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstance

setUpdateSagaInstanceSql(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

shouldApproveOrder() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

shouldRejectOrder() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.AbstractOrdersAndCustomersIntegrationTest

SimpleSaga<Data> - Interface in io.eventuate.tram.sagas.simpledsl

SimpleSagaDefinition<Data> - Class in io.eventuate.tram.sagas.simpledsl

SimpleSagaDefinition(List<SagaStep<Data>>) - Constructor for class io.eventuate.tram.sagas.simpledsl.SimpleSagaDefinition

SimpleSagaDefinitionBuilder<Data> - Class in io.eventuate.tram.sagas.simpledsl

SimpleSagaDefinitionBuilder() - Constructor for class io.eventuate.tram.sagas.simpledsl.SimpleSagaDefinitionBuilder

SimpleSagaDsl<Data> - Interface in io.eventuate.tram.sagas.simpledsl

start(Data) - Method in interface io.eventuate.tram.sagas.orchestration.SagaDefinition

start(Data) - Method in class io.eventuate.tram.sagas.simpledsl.SimpleSagaDefinition

startCompensating() - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

StartingHandler<Data> - Interface in io.eventuate.tram.sagas.orchestration

StashedMessage - Class in io.eventuate.tram.sagas.common

StashedMessage(String, String, Message) - Constructor for class io.eventuate.tram.sagas.common.StashedMessage

stashMessage(String, String, String, Message) - Method in interface io.eventuate.tram.sagas.common.SagaLockManager

stashMessage(String, String, String, Message) - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

StashMessageRequiredException - Exception in io.eventuate.tram.sagas.common

StashMessageRequiredException(String) - Constructor for exception io.eventuate.tram.sagas.common.StashMessageRequiredException

step() - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

step() - Method in class io.eventuate.tram.sagas.simpledsl.LocalStepBuilder

step() - Method in interface io.eventuate.tram.sagas.simpledsl.SimpleSagaDsl

StepBuilder<Data> - Class in io.eventuate.tram.sagas.simpledsl

StepBuilder(SimpleSagaDefinitionBuilder<Data>) - Constructor for class io.eventuate.tram.sagas.simpledsl.StepBuilder

StepOutcome - Class in io.eventuate.tram.sagas.simpledsl

StepOutcome() - Constructor for class io.eventuate.tram.sagas.simpledsl.StepOutcome

StepToExecute<Data> - Class in io.eventuate.tram.sagas.simpledsl

StepToExecute(Optional<SagaStep<Data>>, int, boolean) - Constructor for class io.eventuate.tram.sagas.simpledsl.StepToExecute

subscribe() - Method in class io.eventuate.tram.sagas.eventsourcingsupport.SagaReplyRequestedEventSubscriber

subscribeToReplyChannel() - Method in interface io.eventuate.tram.sagas.orchestration.SagaManager

subscribeToReplyChannel() - Method in class io.eventuate.tram.sagas.orchestration.SagaManagerImpl

subtract(Money) - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

successReply() - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

successReply(Object) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

T

to(String) - Method in class io.eventuate.tram.sagas.testing.SagaUnitTestSupport

toString() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

toString() - Method in class io.eventuate.tram.sagas.orchestration.EnlistedAggregate

toString() - Method in class io.eventuate.tram.sagas.simpledsl.SagaExecutionState

toString() - Method in class io.eventuate.tram.sagas.testing.MessageWithDestination

tramCommandsAndEventsIntegrationData() - Method in class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.CommonIntegrationTestFactory

TramCommandsAndEventsIntegrationData - Class in io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests

TramCommandsAndEventsIntegrationData() - Constructor for class io.eventuate.examples.tram.sagas.ordersandcustomers.micronaut.tests.TramCommandsAndEventsIntegrationData

TramSagaInMemoryConfiguration - Class in io.eventuate.tram.sagas.spring.inmemory

TramSagaInMemoryConfiguration() - Constructor for class io.eventuate.tram.sagas.spring.inmemory.TramSagaInMemoryConfiguration

transformUpdate(CommandProcessingAggregate, UpdateEventsAndOptions) - Method in class io.eventuate.tram.sagas.eventsourcingsupport.CommandMessageAggregateRepositoryInterceptor

U

UnhandledMessageTrackingCommandDispatcher - Class in io.eventuate.tram.sagas.testing.commandhandling

UnhandledMessageTrackingCommandDispatcher(String, CommandHandlers, MessageConsumer, MessageProducer) - Constructor for class io.eventuate.tram.sagas.testing.commandhandling.UnhandledMessageTrackingCommandDispatcher

unlock(String, String) - Method in interface io.eventuate.tram.sagas.common.SagaLockManager

unlock(String, String) - Method in class io.eventuate.tram.sagas.common.SagaLockManagerImpl

update(SagaInstance) - Method in interface io.eventuate.tram.sagas.orchestration.SagaInstanceRepository

update(SagaInstance) - Method in class io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

UpdatingOptionsBuilder - Class in io.eventuate.tram.sagas.eventsourcingsupport

UpdatingOptionsBuilder(CommandMessage) - Constructor for class io.eventuate.tram.sagas.eventsourcingsupport.UpdatingOptionsBuilder

V

valueOf(String) - Static method in enum io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.OrderState

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.eventuate.examples.tram.sagas.ordersandcustomers.orders.domain.OrderState

Returns an array containing the constants of this enum type, in the order they are declared.

verifyCommandReceived() - Method in class io.eventuate.tram.sagas.testing.commandhandling.SagaParticipantStubCommandHandler

verifyCommandReceived(String, Class<C>) - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

visit(Consumer<Optional<RuntimeException>>, Consumer<List<CommandWithDestination>>) - Method in class io.eventuate.tram.sagas.simpledsl.StepOutcome

W

when(C) - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

when(Class<C>) - Method in class io.eventuate.tram.sagas.testing.SagaParticipantStubManager

withChannel(String) - Method in class io.eventuate.tram.sagas.simpledsl.CommandEndpointBuilder

withCommand(CommandWithDestination) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

withCommand(C) - Method in class io.eventuate.tram.sagas.simpledsl.ParticipantInvocationBuilder

withCommands(List<CommandWithDestination>) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

withCompensation(Function<Data, CommandWithDestination>) - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

withCompensation(Predicate<Data>, Function<Data, CommandWithDestination>) - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

withCompensation(CommandEndpoint<C>, Function<Data, C>) - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

withCompensation(Predicate<Data>, CommandEndpoint<C>, Function<Data, C>) - Method in class io.eventuate.tram.sagas.simpledsl.InvokeParticipantStepBuilder

withCompensation(Consumer<Data>) - Method in class io.eventuate.tram.sagas.simpledsl.LocalStepBuilder

withCompensation(Function<Data, CommandWithDestination>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

withCompensation(Predicate<Data>, Function<Data, CommandWithDestination>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

withCompensation(CommandEndpoint<C>, Function<Data, C>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

withCompensation(Predicate<Data>, CommandEndpoint<C>, Function<Data, C>) - Method in class io.eventuate.tram.sagas.simpledsl.StepBuilder

withCompensation(Function<Data, CommandWithDestination>) - Method in interface io.eventuate.tram.sagas.simpledsl.WithCompensationBuilder

withCompensation(Predicate<Data>, Function<Data, CommandWithDestination>) - Method in interface io.eventuate.tram.sagas.simpledsl.WithCompensationBuilder

withCompensation(CommandEndpoint<C>, Function<Data, C>) - Method in interface io.eventuate.tram.sagas.simpledsl.WithCompensationBuilder

withCompensation(Predicate<Data>, CommandEndpoint<C>, Function<Data, C>) - Method in interface io.eventuate.tram.sagas.simpledsl.WithCompensationBuilder

WithCompensationBuilder<Data> - Interface in io.eventuate.tram.sagas.simpledsl

withIsCompensating(boolean) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

withIsEndState(boolean) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

withIsLocal(Optional<RuntimeException>) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

withLock(Class, Object) - Static method in class io.eventuate.tram.sagas.participant.SagaReplyMessageBuilder

withPostLock(PostLockFunction<C>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

withPreLock(BiFunction<CommandMessage<C>, PathVariables, LockTarget>) - Method in class io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder

withReply(Class<T>) - Method in class io.eventuate.tram.sagas.simpledsl.CommandEndpointBuilder

withSuccess(Object) - Method in class io.eventuate.tram.sagas.participant.SagaReplyMessageBuilder

withSuccess() - Method in class io.eventuate.tram.sagas.participant.SagaReplyMessageBuilder

withUpdatedSagaData(Data) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

withUpdatedState(String) - Method in class io.eventuate.tram.sagas.orchestration.SagaActions.Builder

Z

ZERO - Static variable in class io.eventuate.examples.tram.sagas.ordersandcustomers.commondomain.Money

A B C D E F G H I L M N O P R S T U V W Z