io.simplesource.saga.model.serdes

Interface ActionSerdes<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 interface ActionSerdes<A>

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

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<ActionId>	actionId() Serde for the action id.
org.apache.kafka.common.serialization.Serde<io.simplesource.api.CommandId>	commandId() Serde for the command id.
org.apache.kafka.common.serialization.Serde<ActionRequest<A>>	request() Serde for an action request.
org.apache.kafka.common.serialization.Serde<ActionResponse<A>>	response() Serde for an action 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

actionId

org.apache.kafka.common.serialization.Serde<ActionId> actionId()

Serde for the action id.

Returns:

the serde

commandId

org.apache.kafka.common.serialization.Serde<io.simplesource.api.CommandId> commandId()

Serde for the command id.

Returns:

the serde

request

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

Serde for an action request.

Returns:

the serde

response

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

Serde for an action response.

Returns:

the serde