messagebus

Documentation

Overview

Package messagebus routes messages (contract calls & responses) and delivers'em to relevant modules.

Usage:

TODO:

Index

• type MessageBus
  • func NewMessageBus(configuration.Configuration) (*MessageBus, error)
  • func (mb *MessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *MessageBus) Register(p core.MessageType, handler core.MessageHandler) error
  • func (mb *MessageBus) Send(msg core.Message) (core.Reply, error)
  • func (mb *MessageBus) SendAsync(msg core.Message)
  • func (mb *MessageBus) Start(c core.Components) error
  • func (mb *MessageBus) Stop() error

Types

type MessageBus

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

MessageBus is component that routes application logic requests, e.g. glue between network and logic runner

func NewMessageBus

func NewMessageBus(configuration.Configuration) (*MessageBus, error)

NewMessageBus is a `MessageBus` constructor

func (*MessageBus) MustRegister

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

MustRegister is a Register wrapper that panics if an error was returned.

func (*MessageBus) Register

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

Register sets a function as a hadler for particular message type, only one handler per type is allowed

func (*MessageBus) Send

func (mb *MessageBus) Send(msg core.Message) (core.Reply, error)

Send an `Message` and get a `Reply` or error from remote host.

func (*MessageBus) SendAsync

func (mb *MessageBus) SendAsync(msg core.Message)

SendAsync sends a `Message` to remote host.

func (*MessageBus) Start

func (mb *MessageBus) Start(c core.Components) error

Start initializes message bus

func (*MessageBus) Stop

func (mb *MessageBus) Stop() error

Stop releases resources and stops the bus