io.simplesource.saga.model.serdes

Interface SagaClientSerdes<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 Known Subinterfaces:

SagaSerdes<A>

public interface SagaClientSerdes<A>

The serdes required to serialize and deserialize the saga request and response topics.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<SagaRequest<A>>	request() Serde for the saga request.
org.apache.kafka.common.serialization.Serde<SagaResponse>	response() Serde for the saga response.
org.apache.kafka.common.serialization.Serde<SagaId>	sagaId() Serde for the saga id.

Method Detail

sagaId

org.apache.kafka.common.serialization.Serde<SagaId> sagaId()

Serde for the saga id.

Returns:

the serde

request

org.apache.kafka.common.serialization.Serde<SagaRequest<A>> request()

Serde for the saga request.

Returns:

the serde

response

org.apache.kafka.common.serialization.Serde<SagaResponse> response()

Serde for the saga response.

Returns:

the serde