nats

Jul 17, 2019

Changes in this version

type StackExchange

+ SubjectPrefix string

Jul 14, 2019

Changes in this version

+ func With(options nats.Options) nats.Option

+ type StackExchange struct

+ func NewStackExchange(url string, options ...nats.Option) (*StackExchange, error)

+ func (exc *StackExchange) Ask(ctx context.Context, msg neffos.Message, token string) (response neffos.Message, err error)

+ func (exc *StackExchange) NotifyAsk(msg neffos.Message, token string) error

+ func (exc *StackExchange) OnConnect(c *neffos.Conn) error

+ func (exc *StackExchange) OnDisconnect(c *neffos.Conn)

+ func (exc *StackExchange) Publish(msg neffos.Message) bool

+ func (exc *StackExchange) Subscribe(c *neffos.Conn, namespace string)

+ func (exc *StackExchange) Unsubscribe(c *neffos.Conn, namespace string)