io.simplesource.saga.model.messages

Class ActionRequest<A>

java.lang.Object

io.simplesource.saga.model.messages.ActionRequest<A>

Type Parameters:

A - a representation of an action command that is shared across all actions in the saga. This is typically a generic type, such as Json, or if using Avro serialization, SpecificRecord or GenericRecord

public class ActionRequest<A>
extends Object

An action request, published by the saga coordinator in the action request topic.

The action request topic is the topic for actionCommand.actionType action type (note that each action type has its own set of request and respense topics).

The action processor for this action type consumes this request, starts processing the action, and publishes an ActionResponse when processing is complete.

The action request and response is essentially the interface between the saga coordinator and the action processor. Although the saga coordinator and action processor can be hosted in different processes, they must share the same A type, and also must have Serdes that are compatible with each other.

Field Summary

Fields

Modifier and Type	Field and Description
ActionCommand<A>	actionCommand The Action command specifies the details of the command required for processing by the action processor.
ActionId	actionId The action id uniquely identifies an action in the saga dependency graph.
Boolean	isUndo Indicates whether or not this action is processing in undo (compensation) mode.
SagaId	sagaId The saga id uniquely identifies the saga, and is used as the key for the action request and responses.

Constructor Summary

Constructors

Constructor and Description
ActionRequest()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

sagaId

public final SagaId sagaId

The saga id uniquely identifies the saga, and is used as the key for the action request and responses.

actionId

public final ActionId actionId

The action id uniquely identifies an action in the saga dependency graph.

actionCommand

public final ActionCommand<A> actionCommand

The Action command specifies the details of the command required for processing by the action processor.

isUndo

public final Boolean isUndo

Indicates whether or not this action is processing in undo (compensation) mode.

Constructor Detail

ActionRequest

public ActionRequest()