application

Documentation

Index

• type MessageBroker
  • func NewMessageBroker(channel chan mb_domain.Event) *MessageBroker
  • func (mb *MessageBroker) ProcessEvent()
  • func (mb *MessageBroker) PublishEvent(event mb_domain.Event)

Types

type MessageBroker

type MessageBroker struct {
	// contains filtered or unexported fields
}

func NewMessageBroker

func NewMessageBroker(channel chan mb_domain.Event) *MessageBroker

func (*MessageBroker) ProcessEvent

func (mb *MessageBroker) ProcessEvent()

func (*MessageBroker) PublishEvent

func (mb *MessageBroker) PublishEvent(event mb_domain.Event)