Documentation
¶
Index ¶
- func NewIntegrationEventHandlers(reg registry.Registry, orchestrator sec.Orchestrator[*models.CreateOrderData], ...) am.MessageHandler
- func NewReplyHandlers(reg registry.Registry, orchestrator sec.Orchestrator[*models.CreateOrderData], ...) am.MessageHandler
- func RegisterIntegrationEventHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) (err error)
- func RegisterIntegrationEventHandlersTx(container di.Container) error
- func RegisterReplyHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) error
- func RegisterReplyHandlersTx(container di.Container) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewIntegrationEventHandlers ¶
func NewIntegrationEventHandlers(reg registry.Registry, orchestrator sec.Orchestrator[*models.CreateOrderData], mws ...am.MessageHandlerMiddleware) am.MessageHandler
func NewReplyHandlers ¶
func NewReplyHandlers(reg registry.Registry, orchestrator sec.Orchestrator[*models.CreateOrderData], mws ...am.MessageHandlerMiddleware) am.MessageHandler
func RegisterIntegrationEventHandlers ¶
func RegisterIntegrationEventHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) (err error)
func RegisterReplyHandlers ¶
func RegisterReplyHandlers(subscriber am.MessageSubscriber, handlers am.MessageHandler) error
func RegisterReplyHandlersTx ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.