rabbitmq

Oct 26, 2021

Changes in this version

+ type Config struct

+ Host string

+ Password string

+ Port int

+ User string

+ VHost string

+ type RabbitMQClient struct

+ Ch *amqp.Channel

+ ExName string

+ QueueName string

+ func NewRecvClient(c RecvConfig) (*RabbitMQClient, error)

+ func NewSendClient(c SendConfig) (*RabbitMQClient, error)

+ func (c *RabbitMQClient) Consume(f RecvHander, isPallal bool) error

+ func (c *RabbitMQClient) Send(routeKey string, msg []byte) error

+ type RecvConfig struct

+ ExName string

+ QueueName string

+ RouteKey string

+ type RecvHander func(msg []byte) bool

+ type SendConfig struct

+ ExName string