queue

Documentation

Index

• func StartRedisQueue(queueKey, queueGroupName string) error
• type Queue

Functions

func StartRedisQueue

func StartRedisQueue(queueKey, queueGroupName string) error

Types

type Queue

type Queue interface {
	/*
		消息入队，返回消息id
	*/
	Enqueue(key string, message redis.IMessage) (string, error)
	Read(key, groupName string, message redis.IMessage) error
	Start(queueKey, queueGroupName string) error
}