First, You must create or have a output port in the application service layer. So, You create an adapter for implement these port.
flowchart LR
subgraph application service
output_port
end
subgraph messaging module
secondary_adapter
end
output_port --> secondary_adapter
Part I.
- Models from Event Specification(e.g: Avro Models)
- Mappers
Part II.
- Implementing output ports(Publishers/Producers)
- Secondary Adapter
- Implementing input ports(Listener/Consumers)
- Primary Adapter