consumer

Documentation

Index

• type Consumer
  • func (c *Consumer) Run() *Consumer
• type OrderMsg

Types

type Consumer

type Consumer struct {
	AMQP   *rabbitmq.AMQP
	Logger *logger.Logger
	Handle *handle.MqHandle
	// 声明消费者
	OrderConsumer *rabbitmq.Consumer // 订单
}

func (*Consumer) Run

func (c *Consumer) Run() *Consumer

type OrderMsg

type OrderMsg struct {
	Id      int64  `json:"id"`
	Tid     int64  `json:"tid"`
	Cid     int64  `json:"cid"`
	Sid     int64  `json:"sid"`
	OrderSn string `json:"order_sn"`
}