gotrade: Index | Files | Directories

package messagebus

import ""


Package Files

config.go messagebus.go


const DefaultUrl = nats.DefaultURL

type Config Uses

type Config struct {
    Url string

Config represents the configuration.

func NewConfig Uses

func NewConfig(url string) *Config

NewConfig returns an instance of Config with defaults.

type MessageBus Uses

type MessageBus struct {
    Config     *Config
    Connection *nats.Conn

func NewMessageBus Uses

func NewMessageBus(config *Config) (*MessageBus, error)

Create new message bus wrapper, for this repo NATS is hardcoded. This module should serve as message routing across multiple protocols (RMQ, 0MQ, Tibrv etc)

func (*MessageBus) Close Uses

func (m *MessageBus) Close()

Close underlying messaging bus driver

type Msg Uses

type Msg nats.Msg



Package messagebus imports 1 packages (graph) and is imported by 3 packages. Updated 2016-07-20. Refresh now. Tools for package owners.