msgqueue

package

v0.0.3 Latest Latest Go to latest Published: Nov 15, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/QOSGroup/cassini

Links

Open Source Insights

Documentation ¶

Overview ¶

Package msgqueue 从消息队列服务收发消息

Index ¶

func StartQcpConsume(conf *config.Config) (err error)
type NATSConsumer
type NATSProducer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func StartQcpConsume ¶

func StartQcpConsume(conf *config.Config) (err error)

StartQcpConsume Start to consume tx msg

Types ¶

type NATSConsumer ¶

type NATSConsumer struct {
	CallBack func(msg *nats.Msg) //处理消息的回调函数
	// contains filtered or unexported fields
}

NATSConsumer Gnatsd consumer

func (*NATSConsumer) Connect ¶

func (n *NATSConsumer) Connect() (nc *nats.Conn, err error)

Connect Connect to gnatsd server

func (*NATSConsumer) Consume ¶

func (n *NATSConsumer) Consume(nc *nats.Conn) (err error)

Consume Consume tx msg

func (*NATSConsumer) Reply ¶

func (n *NATSConsumer) Reply(nc *nats.Conn) error

Reply Consume tx msg and reply a msg

type NATSProducer ¶

type NATSProducer struct {
	ServerUrls string //消息队列服务地址，多个用","分割  例如 "nats://192.168.168.195:4222，nats://192.168.168.195:4223"

	Subject string //主题
}

func (*NATSProducer) Connect ¶

func (n *NATSProducer) Connect() (nc *nats.Conn, err error)

func (*NATSProducer) Produce ¶

func (n *NATSProducer) Produce(nc *nats.Conn, msg []byte) (err error)

func (*NATSProducer) ProduceWithReply ¶

func (n *NATSProducer) ProduceWithReply(nc *nats.Conn, reply string, payload []byte) error

TODO

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL