39 lines
926 B
Plaintext
39 lines
926 B
Plaintext
@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
|
|
|