controller

Documentation

Index

• func Init()
• func ReSendFailedMessage(c *gin.Context) models.Result[any]
• func SendMessage(c *gin.Context) models.Result[any]

Functions

func Init

func Init()

func ReSendFailedMessage

func ReSendFailedMessage(c *gin.Context) models.Result[any]

ReSendFailedMessage godoc @Summary 重新发送指定时间段内的失败消息 @Description 重新发送指定时间段内的失败消息 @Tags 发布 @Accept x-www-form-urlencoded @Produce json @Param queue formData string false "消息队列名，不传为配置中的所有队列" @Param start formData string false "开始时间，格式 yyyy-MM-dd HH:mm:ss,不传默认为当天0点" @Param end formData string false "结束时间，格式 yyyy-MM-dd HH:mm:ss,不传默认为当前时间" @Success 200 {string} string "ok" @Router /msg/resend [post]

func SendMessage

func SendMessage(c *gin.Context) models.Result[any]

SendMessage godoc @Summary 发送一条消息到消息队列 @Description 发送一条消息到消息队列 @Tags 发布 @Accept x-www-form-urlencoded @Produce json @Param queue formData string true "消息队列名" @Param msg formData string true "消息内容，必须是mgin中的client.Options格式或map格式，在yml文件中配置paramType" @Success 200 {string} string "ok" @Router /msg/send [post]