testmessagebus

Documentation

Index

• type TestMessageBus
  • func NewTestMessageBus() *TestMessageBus
  • func (mb *TestMessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *TestMessageBus) ReRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *TestMessageBus) Register(p core.MessageType, handler core.MessageHandler) error
  • func (mb *TestMessageBus) Send(ctx core.Context, m core.Message) (core.Reply, error)
  • func (mb *TestMessageBus) Start(components core.Components) error
  • func (mb *TestMessageBus) Stop() error

Types

type TestMessageBus

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

func NewTestMessageBus

func NewTestMessageBus() *TestMessageBus

func (*TestMessageBus) MustRegister

func (mb *TestMessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)

func (*TestMessageBus) ReRegister

func (mb *TestMessageBus) ReRegister(p core.MessageType, handler core.MessageHandler)

func (*TestMessageBus) Register

func (mb *TestMessageBus) Register(p core.MessageType, handler core.MessageHandler) error

func (*TestMessageBus) Send

func (mb *TestMessageBus) Send(ctx core.Context, m core.Message) (core.Reply, error)

func (*TestMessageBus) Start

func (mb *TestMessageBus) Start(components core.Components) error

func (*TestMessageBus) Stop

func (mb *TestMessageBus) Stop() error