Documentation
¶
Index ¶
- Variables
- func ConsumerCoroutineSameTypeDataLock(msg <-chan amqp.Delivery, taskName string, fieldName []string, syncNumber int, ...)
- func CreateChannel(conn *amqp.Connection, taskName string, durable bool) (channel *amqp.Channel, err error)
- func CreateConsumer(taskName string, conn *amqp.Connection, deliveryMode bool) (msg <-chan amqp.Delivery, err error)
- func CreateConsumerHandler[T any](taskData *types.RegisterHandler[T]) (err error)
- func FastPublish(channel *amqp.Channel, taskName string, data any, deliveryMode bool) (err error)
- func GetConn() (conn *amqp.Connection, err error)
- func GetConsumer(taskName string, deliveryMode bool) (msg <-chan amqp.Delivery, err error)
- func QueueService(list map[string]error)
- func SendQueue(taskName string, data any, deliveryMode bool) (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var MQCoroutineLock = gmlock.New()
MQCoroutineLock MQ 协程 锁
Functions ¶
func ConsumerCoroutineSameTypeDataLock ¶
func ConsumerCoroutineSameTypeDataLock(msg <-chan amqp.Delivery, taskName string, fieldName []string, syncNumber int, callback func(item *gjson.Json) error)
ConsumerCoroutineSameTypeDataLock 消费者 协程 同类型数据锁
func CreateChannel ¶
func CreateChannel(conn *amqp.Connection, taskName string, durable bool) (channel *amqp.Channel, err error)
CreateChannel 创建一个连接通道
func CreateConsumer ¶
func CreateConsumer(taskName string, conn *amqp.Connection, deliveryMode bool) (msg <-chan amqp.Delivery, err error)
CreateConsumer 创建一个消费者
func CreateConsumerHandler ¶
func CreateConsumerHandler[T any](taskData *types.RegisterHandler[T]) (err error)
CreateConsumerHandler 创建一个执行消费者
func FastPublish ¶
FastPublish 快速进行队列消息推送
func GetConsumer ¶
GetConsumer 获得一个直接可使用的消费者
func QueueService ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.