@startuml Messaging Sequenzdiagramm Rechts

participant Kafka

group "Persistence: Request verarbeiten und Response produzieren"

Transaction -> CommandWrapper : process(cmdW)
CommandWrapper -> Command : <<reflection>>\ndeserialize(cmdW)
CommandWrapper <-- Command : cmd

CommandWrapper -> Command : process(cmd)

Command -> CDI : select(Class)
Command <-- CDI : Processor

Command -> Processor : process(cmd)
note over Processor : Verarbeitung\ndes Commands
Command <-- Processor : resp

CommandWrapper <-- Command : resp
Transaction <-- CommandWrapper : resp

Transaction -> CommandResponse : serialize(resp).copyIds(cmdW)
Transaction <-- CommandResponse : respW

Transaction -> Interceptor : intercept(respW)
note over Interceptor : (asynchron;\nDetails nicht\ndargestellt)
Transaction <-- Interceptor

Transaction -> Transaction : commit()

Transaction -> Kafka : produce(respW)
Transaction <-- Kafka : Ack

end

@enduml