Versions in this module Expand all Collapse all v1 v1.0.0 Sep 1, 2022 Changes in this version + func ConsumeQueue(cq *ChannelQueue, handler ConsumeHandler) + func PublishTask(cq *ChannelQueue, data CommandData) + type ChannelQueue struct + Channel *amqp.Channel + Queue *amqp.Queue + func DeclareQueue(queueName string, handler CloseHandler) (cq *ChannelQueue) + type CloseHandler func(cq *ChannelQueue) + type CommandData struct + Act string + Args map[string]string + MaxTry int + TryTime int + type ConsumeHandler func(cq *ChannelQueue, data CommandData)