message_queue

May 27, 2020

Changes in this version

+ var ChanelPushNotify Chanel = "push_notify"

+ var TopicPushNotify Topic = "push_notify"

+ type SendNotifyBody struct

+ Event notify.SendNotifyEvent

+ Payload interface{}

+ func (c *SendNotifyBody) ToByte() ([]byte, error)

May 12, 2020

Changes in this version

+ var Address string

+ var ChanelSendEmail Chanel = "send_email"

+ var Config *nsq.Config

+ var TopicSendEmail Topic = "send_email"

+ 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 string

+ type SendActivationEmailBody struct

+ Code string

+ Email string

+ type Topic string