Documentation
¶
Index ¶
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CommonDelayQueueConsume ¶
func CommonDelayQueueConsume(callbackConfig map[string]interface{})
延迟队列消费者
func CommonFanoutQueueConsume ¶
func CommonFanoutQueueConsume(callbackConfig map[string]interface{})
func IntoCommonFanoutQueue ¶
func IntoCommonFanoutQueue(param rmqstruct.QueueBroadcastParam)
进入广播交换机，默认交换机
func IntoFanoutQueue ¶
func IntoFanoutQueue(param rmqstruct.QueueBroadcastParam, exchange string)
自定义广播交换机
func IntoQueue ¶
func IntoQueue(param rmqstruct.QueueParam)
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.