utils

Documentation

Index

• Variables
• func BindRoutingKey(api, user, passwd, vhost, name, exchange, key string) error
• func CreateQueue(api, user, passwd, vhost, name string) error
• func FakeIdDecode(str string) int64
• func FakeIdEncode(number int64) string
• func NewReceiveConsumer(url string) (*receiveConsumer, error)
• func RegisterQueue(api, user, passwd, vhost, name, exchange, key string) error
• type ReceiveTool
  • func NewTool(url, exchange string, routeKeys []string) (*ReceiveTool, error)
  • func (c *ReceiveTool) Publish(route, msg string)

Variables

var Logger *zap.Logger

Functions

func BindRoutingKey

func BindRoutingKey(api, user, passwd, vhost, name, exchange, key string) error

func CreateQueue

func CreateQueue(api, user, passwd, vhost, name string) error

func FakeIdDecode

func FakeIdDecode(str string) int64

func FakeIdEncode

func FakeIdEncode(number int64) string

func NewReceiveConsumer

func NewReceiveConsumer(url string) (*receiveConsumer, error)

func RegisterQueue

func RegisterQueue(api, user, passwd, vhost, name, exchange, key string) error

Types

type ReceiveTool

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

func NewTool

func NewTool(url, exchange string, routeKeys []string) (*ReceiveTool, error)

func (*ReceiveTool) Publish

func (c *ReceiveTool) Publish(route, msg string)