types

Documentation

Index

• Constants
• type Consumer
• type ConsumerMessageHandle
• type Producer
• type Result

Constants

const (
	ExchangeTypeDirect  = "direct"
	ExchangeTypeFanout  = "fanout"
	ExchangeTypeTopic   = "topic"
	ExchangeTypeHeaders = "headers"
)

Types

type Consumer

type Consumer struct {
	Exchange            string
	RoutingKey          string
	Queue               string
	Type                string
	Durable             bool
	AutoDeletedExchange bool
	AutoDeletedQueue    bool
	Handler             ConsumerMessageHandle
}

type ConsumerMessageHandle

type ConsumerMessageHandle = func(data []byte) Result

type Producer

type Producer struct {
	Exchange    string
	RoutingKey  string
	Data        any
	Expiration  string //过期时间，毫秒
	Persistence bool   //持久化消息
	Priority    uint8  //优先级0-9
}

type Result

type Result = byte