handler

Documentation

Index

• Constants
• type EmailHandler
  • func NewEmailHandler(url string) *EmailHandler
  • func (s *EmailHandler) Publisher() rabbitmq.MessagePublisher
  • func (s *EmailHandler) ReceiveMessage(handler func(message string)) error
  • func (s *EmailHandler) SendMessage(message string) error
  • func (s *EmailHandler) Subscriber() rabbitmq.MessageSubscriber

Constants

const (
	// email交换机
	EMAIL_EXCHANGE = "email_exchange"
	// email队列
	EMAIL_QUEUE = "email_queue"
)

Types

type EmailHandler

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

func NewEmailHandler

func NewEmailHandler(url string) *EmailHandler

func (*EmailHandler) Publisher

func (s *EmailHandler) Publisher() rabbitmq.MessagePublisher

func (*EmailHandler) ReceiveMessage

func (s *EmailHandler) ReceiveMessage(handler func(message string)) error

func (*EmailHandler) SendMessage

func (s *EmailHandler) SendMessage(message string) error

func (*EmailHandler) Subscriber

func (s *EmailHandler) Subscriber() rabbitmq.MessageSubscriber