Versions in this module Expand all Collapse all v0 v0.0.1 May 7, 2017 Changes in this version + const PriorityHigh + const PriorityLow + const PriorityNormal + type Handler func([]byte) error + type Message struct + Body []byte + Created time.Time + ID string + Priority uint8 + Type string + func NewMessage(p uint8, t string, v interface{}) (*Message, error) + func (p *Message) Parse(v interface{}) error + type Queue interface + Receive func(n string, f func(*Message) error) error + Send func(m *Message) error + type Server struct + Queue Queue + func New() *Server + func (p *Server) Do(name string) error + func (p *Server) Register(t string, f Handler) + func (p *Server) Send(prv uint8, typ string, val interface{}) error + func (p *Server) Status() map[string]string