io.simplesource.saga.serialization.avro

Interface AvroSerdes.Generic

Enclosing class:

AvroSerdes

public static interface AvroSerdes.Generic

Factory methods which can be used where A is a subclass of GenericRecord.

Method Summary

Modifier and Type	Method and Description
static <A extends org.apache.avro.generic.GenericRecord> 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.generic.GenericRecord> 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.generic.GenericRecord> 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.generic.GenericRecord> 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 GenericRecord

Parameters:

schemaRegistryUrl - the schema registry url

useMockSchemaRegistry - the use mock schema registry

Returns:

the action serdes

sagaClientSerdes

static <A extends org.apache.avro.generic.GenericRecord> 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 GenericRecord

Parameters:

schemaRegistryUrl - the schema registry url

useMockSchemaRegistry - the use mock schema registry

Returns:

the saga client serdes

sagaSerdes

static <A extends org.apache.avro.generic.GenericRecord> 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 GenericRecord

Parameters:

schemaRegistryUrl - the schema registry url

useMockSchemaRegistry - the use mock schema registry

Returns:

the saga client serdes