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) 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, takes an executor object that satisfies LogicRunner interface

func (*MessageBus) Register

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

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

func (*MessageBus) Stop

func (mb *MessageBus) Stop() error