Versions in this module Expand all Collapse all v0 v0.0.8 Nov 25, 2022 Changes in this version + func CommonDelayQueueConsume(callbackConfig map[string]interface{}) + func CommonFanoutQueueConsume(callbackConfig map[string]interface{}) + func CommonQueueConsume(callbackConfig map[string]interface{}) + func IntoCommonFanoutQueue(param rmqstruct.QueueBroadcastParam) + func IntoDelayQueue(param rmqstruct.QueueParam, delay int) + func IntoFanoutQueue(param rmqstruct.QueueBroadcastParam, exchange string) + func IntoQueue(param rmqstruct.QueueParam)