Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/assembla/cony
/ newTestConsumer
Function
newTestConsumer
consumer_test.go:319–322 ·
view source on GitHub ↗
(opts ...ConsumerOpt)
Source
from the content-addressed store, hash-verified
317
}
318
319
func
newTestConsumer(opts ...ConsumerOpt) *Consumer {
320
q := &Queue{}
321
return
NewConsumer(q, opts...)
322
}
Callers
14
TestAutoAck
Function · 0.85
TestAutoTag
Function · 0.85
TestConsumer_Cancel
Function · 0.85
TestConsumer_Cancel_willNotBlock
Function · 0.85
TestConsumer_Deliveries
Function · 0.85
TestConsumer_Errors
Function · 0.85
TestConsumer_reportErr
Function · 0.85
TestConsumer_serve_qos
Function · 0.85
TestConsumer_serve_Consume
Function · 0.85
TestConsumer_serve_for
Function · 0.85
TestExclusive
Function · 0.85
TestNoLocal
Function · 0.85
Calls
1
NewConsumer
Function · 0.85
Tested by
no test coverage detected