Package | Description |
---|---|
io.simplesource.saga.action.app | |
io.simplesource.saga.action.eventsourcing | |
io.simplesource.saga.model.specs | |
io.simplesource.saga.serialization.avro |
Modifier and Type | Method and Description |
---|---|
static <A> ActionApp<A> |
ActionApp.of(ActionSerdes<A> serdes) |
Modifier and Type | Method and Description |
---|---|
ActionSerdes<A> |
EventSourcingContext.aSerdes() |
Modifier and Type | Field and Description |
---|---|
ActionSerdes<A> |
ActionSpec.serdes
The Serdes.
|
Modifier and Type | Method and Description |
---|---|
static <A> ActionSerdes<A> |
AvroSerdes.actionSerdes(org.apache.kafka.common.serialization.Serde<A> payloadSerde,
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> |
AvroSerdes.Specific.actionSerdes(String schemaRegistryUrl) |
static <A extends org.apache.avro.generic.GenericRecord> |
AvroSerdes.Generic.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> |
AvroSerdes.Specific.actionSerdes(String schemaRegistryUrl,
boolean useMockSchemaRegistry)
Create action serdes (serdes required for serializing to and from action request and response topics)
|
Copyright © 2019. All rights reserved.