Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageHandler ¶
type MessageHandler interface { Init(settings *config.CloudSettings, logger watermill.LoggerAdapter) error HandleMessage(message *message.Message) ([]*message.Message, error) Name() string Topics() string }
MessageHandler represents the internal interface for implementing a message handler.
Click to show internal directories.
Click to hide internal directories.