rabbitmq

Documentation

Index

• Constants
• type NewNotificationMsg
• type RabbitMQ
  • func (r *RabbitMQ) CloseConnection() (err error)
  • func (r *RabbitMQ) CreateQueue(queueName string) (err error)
  • func (r *RabbitMQ) GetConsumerChan(queue string) (messages <-chan amqp.Delivery, err error)
  • func (r *RabbitMQ) PublishMsg(queue string, message []byte) (err error)
  • func (r *RabbitMQ) Setup(serverURL string) (err error)

Constants

const (
	NotificationQueue = "notification"
)

Types

type NewNotificationMsg

type NewNotificationMsg struct {
	CardID  int    `json:"cardID"`
	Content string `json:"content"`
	UserIDs []int  `json:"userIDs"`
}

type RabbitMQ

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

func (*RabbitMQ) CloseConnection

func (r *RabbitMQ) CloseConnection() (err error)

func (*RabbitMQ) CreateQueue

func (r *RabbitMQ) CreateQueue(queueName string) (err error)

func (*RabbitMQ) GetConsumerChan

func (r *RabbitMQ) GetConsumerChan(queue string) (messages <-chan amqp.Delivery, err error)

func (*RabbitMQ) PublishMsg

func (r *RabbitMQ) PublishMsg(queue string, message []byte) (err error)

func (*RabbitMQ) Setup

func (r *RabbitMQ) Setup(serverURL string) (err error)