com.networknt.saga.dsl

Class ParticipantInvocationStep<Data>

java.lang.Object

com.networknt.saga.dsl.ParticipantInvocationStep<Data>

All Implemented Interfaces:

SagaStep<Data>

public class ParticipantInvocationStep<Data>
extends Object
implements SagaStep<Data>

Constructor Summary

Constructors

Constructor and Description
ParticipantInvocationStep(Optional<ParticipantInvocation<Data>> participantInvocation, Optional<ParticipantInvocation<Data>> compensation, Map<String,BiConsumer<Data,Object>> actionReplyHandlers, Map<String,BiConsumer<Data,Object>> compensationReplyHandlers)

Method Summary

Modifier and Type	Method and Description
Optional<ParticipantInvocation<Data>>	getAction()
Optional<ParticipantInvocation<Data>>	getCompensatingParticipantInvocation()
ParticipantInvocation<Data>	getParticipantInvocation(boolean compensating)
Optional<BiConsumer<Data,Object>>	getReplyHandler(String replyType, boolean compensating)
boolean	hasAction()
boolean	hasCompensation()

Methods inherited from class java.lang.Object

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

Constructor Detail

ParticipantInvocationStep

public ParticipantInvocationStep(Optional<ParticipantInvocation<Data>> participantInvocation,
                                 Optional<ParticipantInvocation<Data>> compensation,
                                 Map<String,BiConsumer<Data,Object>> actionReplyHandlers,
                                 Map<String,BiConsumer<Data,Object>> compensationReplyHandlers)

Method Detail

getParticipantInvocation

public ParticipantInvocation<Data> getParticipantInvocation(boolean compensating)

getCompensatingParticipantInvocation

public Optional<ParticipantInvocation<Data>> getCompensatingParticipantInvocation()

getAction

public Optional<ParticipantInvocation<Data>> getAction()

hasCompensation

public boolean hasCompensation()

hasAction

public boolean hasAction()

getReplyHandler

public Optional<BiConsumer<Data,Object>> getReplyHandler(String replyType,
                                                         boolean compensating)