io.simplesource.saga.serialization.avro

Interface AvroSerdes.Specific

Enclosing class:

AvroSerdes

public static interface AvroSerdes.Specific

Factory methods which can be used where A is a subclass of SpecificRecord. This includes all the types generated from AVDL by the Avro Maven plugin.

Method Summary

Modifier and Type	Method and Description
static <A extends org.apache.avro.specific.SpecificRecord> ActionSerdes<A>	actionSerdes(String schemaRegistryUrl)
static <A extends org.apache.avro.specific.SpecificRecord> ActionSerdes<A>	actionSerdes(String schemaRegistryUrl, boolean useMockSchemaRegistry) Create action serdes (serdes required for serializing to and from action request and response topics)
static <A extends org.apache.avro.specific.SpecificRecord> SagaClientSerdes<A>	sagaClientSerdes(String schemaRegistryUrl, boolean useMockSchemaRegistry) Saga client serdes (serdes required for the saga request and response topics)
static <A extends org.apache.avro.specific.SpecificRecord> SagaSerdes<A>	sagaSerdes(String schemaRegistryUrl, boolean useMockSchemaRegistry) Saga serdes (saga client topics, as well as the saga internal state and state transition topics)

Method Detail

actionSerdes

static <A extends org.apache.avro.specific.SpecificRecord> ActionSerdes<A> actionSerdes(String schemaRegistryUrl)

actionSerdes

static <A extends org.apache.avro.specific.SpecificRecord> ActionSerdes<A> actionSerdes(String schemaRegistryUrl,
                                                                                        boolean useMockSchemaRegistry)

Create action serdes (serdes required for serializing to and from action request and response topics)

Type Parameters:

A - a representation of an action command that is shared across all actions in the saga. This is must be a subclass of SpecificRecord

Parameters:

schemaRegistryUrl - the schema registry url

useMockSchemaRegistry - the use mock schema registry

Returns:

the action serdes

sagaClientSerdes

static <A extends org.apache.avro.specific.SpecificRecord> SagaClientSerdes<A> sagaClientSerdes(String schemaRegistryUrl,
                                                                                                boolean useMockSchemaRegistry)

Saga client serdes (serdes required for the saga request and response topics)

Type Parameters:

A - a representation of an action command that is shared across all actions in the saga. This is must be a subclass of SpecificRecord

Parameters:

schemaRegistryUrl - the schema registry url

useMockSchemaRegistry - the use mock schema registry

Returns:

the saga client serdes

sagaSerdes

static <A extends org.apache.avro.specific.SpecificRecord> SagaSerdes<A> sagaSerdes(String schemaRegistryUrl,
                                                                                    boolean useMockSchemaRegistry)

Saga serdes (saga client topics, as well as the saga internal state and state transition topics)

Type Parameters:

A - a representation of an action command that is shared across all actions in the saga. This is must be a subclass of SpecificRecord

Parameters:

schemaRegistryUrl - the schema registry url

useMockSchemaRegistry - the use mock schema registry

Returns:

the saga client serdes