handler

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

• type EmailHandler
  • func (h *EmailHandler) GetChannel() message_queue.Chanel
  • func (h *EmailHandler) GetTopic() message_queue.Topic
  • func (h *EmailHandler) OnMessage(message *nsq.Message) error
• type Handler
• type NotifyHandler
  • func NewEmailHandler(topic message_queue.Topic, chanel message_queue.Chanel) *NotifyHandler
  • func NewNotifyHandler(topic message_queue.Topic, chanel message_queue.Chanel) *NotifyHandler
  • func (h *NotifyHandler) GetChannel() message_queue.Chanel
  • func (h *NotifyHandler) GetTopic() message_queue.Topic
  • func (h *NotifyHandler) OnMessage(message *nsq.Message) error

Types

type EmailHandler

type EmailHandler struct {
	// contains filtered or unexported fields
}

func (*EmailHandler) GetChannel

func (h *EmailHandler) GetChannel() message_queue.Chanel

func (*EmailHandler) GetTopic

func (h *EmailHandler) GetTopic() message_queue.Topic

func (*EmailHandler) OnMessage

func (h *EmailHandler) OnMessage(message *nsq.Message) error

type Handler

type Handler interface {
	GetTopic() message_queue.Topic
	GetChannel() message_queue.Chanel
	OnMessage(message *nsq.Message) error
}

type NotifyHandler

type NotifyHandler struct {
	// contains filtered or unexported fields
}

func NewEmailHandler

func NewEmailHandler(topic message_queue.Topic, chanel message_queue.Chanel) *NotifyHandler

func NewNotifyHandler

func NewNotifyHandler(topic message_queue.Topic, chanel message_queue.Chanel) *NotifyHandler

func (*NotifyHandler) GetChannel

func (h *NotifyHandler) GetChannel() message_queue.Chanel

func (*NotifyHandler) GetTopic

func (h *NotifyHandler) GetTopic() message_queue.Topic

func (*NotifyHandler) OnMessage

func (h *NotifyHandler) OnMessage(message *nsq.Message) error