io.simplesource.kafka.serialization.json

Class JsonCommandSerdes<K,C>

java.lang.Object

io.simplesource.kafka.serialization.json.JsonCommandSerdes<K,C>

All Implemented Interfaces:

CommandSerdes<K,C>

public final class JsonCommandSerdes<K,C>
extends Object
implements CommandSerdes<K,C>

Field Summary

Fields

Modifier and Type	Field and Description
protected GenericMapper<C,com.google.gson.JsonElement>	commandMapper
protected GenericMapper<K,com.google.gson.JsonElement>	keyMapper

Constructor Summary

Constructors

Constructor and Description
JsonCommandSerdes()
JsonCommandSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper, GenericMapper<C,com.google.gson.JsonElement> commandMapper)

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<K>	aggregateKey()
org.apache.kafka.common.serialization.Serde<CommandId>	commandId()
org.apache.kafka.common.serialization.Serde<CommandRequest<K,C>>	commandRequest()
org.apache.kafka.common.serialization.Serde<CommandResponse<K>>	commandResponse()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

keyMapper

protected final GenericMapper<K,com.google.gson.JsonElement> keyMapper

commandMapper

protected final GenericMapper<C,com.google.gson.JsonElement> commandMapper

Constructor Detail

JsonCommandSerdes

public JsonCommandSerdes()

JsonCommandSerdes

public JsonCommandSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
                         GenericMapper<C,com.google.gson.JsonElement> commandMapper)

Method Detail

aggregateKey

public org.apache.kafka.common.serialization.Serde<K> aggregateKey()

Specified by:

aggregateKey in interface CommandSerdes<K,C>

commandRequest

public org.apache.kafka.common.serialization.Serde<CommandRequest<K,C>> commandRequest()

Specified by:

commandRequest in interface CommandSerdes<K,C>

commandId

public org.apache.kafka.common.serialization.Serde<CommandId> commandId()

Specified by:

commandId in interface CommandSerdes<K,C>

commandResponse

public org.apache.kafka.common.serialization.Serde<CommandResponse<K>> commandResponse()

Specified by:

commandResponse in interface CommandSerdes<K,C>