message_queue

Documentation

Overview

Copyright 2019-2020 Axetroy. All rights reserved. MIT license.

Copyright 2019-2020 Axetroy. All rights reserved. MIT license.

Copyright 2019-2020 Axetroy. All rights reserved. MIT license.

Index

• Variables
• func CreateConsumer(topic Topic, channel Chanel, handler nsq.Handler) (c *nsq.Consumer, err error)
• func Publish(topic Topic, message []byte) (err error)
• func RunMessageQueueConsumer() (*nsq.Consumer, error)
• type Chanel
• type SendActivationEmailBody
• type Topic

Variables

var (
	TopicSendEmail  Topic       = "send_email"
	ChanelSendEmail Chanel      = "send_email"
	Address         string      // 消息队列地址
	Config          *nsq.Config // 消息队列的配置
)

Functions

func CreateConsumer

func CreateConsumer(topic Topic, channel Chanel, handler nsq.Handler) (c *nsq.Consumer, err error)

创建消费者

func Publish

func Publish(topic Topic, message []byte) (err error)

发布消息

func RunMessageQueueConsumer

func RunMessageQueueConsumer() (*nsq.Consumer, error)

Types

type Chanel

type Chanel string

type SendActivationEmailBody

type SendActivationEmailBody struct {
	Email string `json:"email"` // 要发送的邮箱
	Code  string `json:"code"`  // 发送的激活码
}

type Topic

type Topic string