Versions in this module Expand all Collapse all v0 v0.0.3 Nov 15, 2018 v0.0.1 Oct 31, 2018 Changes in this version + func StartQcpConsume(conf *config.Config) (err error) + type NATSConsumer struct + CallBack func(msg *nats.Msg) + func (n *NATSConsumer) Connect() (nc *nats.Conn, err error) + func (n *NATSConsumer) Consume(nc *nats.Conn) (err error) + func (n *NATSConsumer) Reply(nc *nats.Conn) error + type NATSProducer struct + ServerUrls string + Subject string + func (n *NATSProducer) Connect() (nc *nats.Conn, err error) + func (n *NATSProducer) Produce(nc *nats.Conn, msg []byte) (err error) + func (n *NATSProducer) ProduceWithReply(nc *nats.Conn, reply string, payload []byte) error + type QcpConsumer struct
Go to main page