io.simplesource.saga.model.serdes

Interface SagaSerdes<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

All Superinterfaces:

SagaClientSerdes<A>

public interface SagaSerdes<A>
extends SagaClientSerdes<A>

The serdes required to serialize and deserialize the saga state and state transition topics, as well as the request and response topics.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<Saga<A>>	state() Serde for the saga state.
org.apache.kafka.common.serialization.Serde<SagaStateTransition<A>>	transition() Serde for the saga state transitions.

Methods inherited from interface io.simplesource.saga.model.serdes.SagaClientSerdes

request, response, sagaId

Method Detail

state

org.apache.kafka.common.serialization.Serde<Saga<A>> state()

Serde for the saga state.

Returns:

the serde

transition

org.apache.kafka.common.serialization.Serde<SagaStateTransition<A>> transition()

Serde for the saga state transitions.

Returns:

the serde