nats

Documentation

Index

• type MsgHandler
  • func New(cacheImpl *cache.Cache) (*MsgHandler, error)
  • func (handler *MsgHandler) Close()
  • func (handler *MsgHandler) HandleOrderMsg(msg *stan.Msg)
  • func (handler *MsgHandler) Start() error

Types

type MsgHandler

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

func New

func New(cacheImpl *cache.Cache) (*MsgHandler, error)

func (*MsgHandler) Close

func (handler *MsgHandler) Close()

func (*MsgHandler) HandleOrderMsg

func (handler *MsgHandler) HandleOrderMsg(msg *stan.Msg)

func (*MsgHandler) Start

func (handler *MsgHandler) Start() error