Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultConcurrentHandlerCount = 1 DefaultSubscriptionTimeout = int64(5) // second )
DefaultConcurrentHandlerCount ...
View Source
var ( Config = &rabbitmqConfig{ done: make(chan struct{}), } )
Config ...
Functions ¶
func ConcurrentHandlerCount ¶
func ConcurrentHandlerCount(n int) broker.SubscribeOption
ConcurrentHandlerCount ...
func SubscriptionTimeout ¶
func SubscriptionTimeout(d time.Duration) broker.SubscribeOption
SubscriptionTimeout ...
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.