rabbitmq

Documentation

Index

• func ConsumeQueue(cq *ChannelQueue, handler ConsumeHandler)
• func ConsumeQueue2(cq *ChannelQueue, handler ConsumeHandler)
• func PublishTask(cq *ChannelQueue, data CommandData)
• type ChannelQueue
  • func DeclareQueue(queueName string, handler CloseHandler) (cq *ChannelQueue)
• type CloseHandler
• type CommandData
• type ConsumeHandler

Functions

func ConsumeQueue

func ConsumeQueue(cq *ChannelQueue, handler ConsumeHandler)

ConsumeQueue 注册消费队列

func ConsumeQueue2

func ConsumeQueue2(cq *ChannelQueue, handler ConsumeHandler)

ConsumeQueue2 注册消费队列

func PublishTask

func PublishTask(cq *ChannelQueue, data CommandData)

PublishTask 发布队列数据

Types

type ChannelQueue

type ChannelQueue struct {
	Channel *amqp.Channel
	Queue   *amqp.Queue
}

func DeclareQueue

func DeclareQueue(queueName string, handler CloseHandler) (cq *ChannelQueue)

DeclareQueue 声明队列

type CloseHandler

type CloseHandler func(cq *ChannelQueue)

type CommandData

type CommandData struct {
	Act     string            `json:"act"`
	Args    map[string]string `json:"args"`
	TryTime int               `json:"try_time"`
	MaxTry  int               `json:"max_try"`
}

type ConsumeHandler

type ConsumeHandler func(cq *ChannelQueue, data CommandData)