(t *testing.T)
| 281 | } |
| 282 | |
| 283 | func TestNewConsumer(t *testing.T) { |
| 284 | var called bool |
| 285 | |
| 286 | NewConsumer(&Queue{}, func(*Consumer) { |
| 287 | called = true |
| 288 | }) |
| 289 | |
| 290 | if !called { |
| 291 | t.Error("NewConsumer should call input functional options") |
| 292 | } |
| 293 | } |
| 294 | |
| 295 | func TestNoLocal(t *testing.T) { |
| 296 | c := newTestConsumer(NoLocal()) |
nothing calls this directly
no test coverage detected