Function TestTag

consumer_test.go:311–317

(t *testing.T)

}

func TestTag(t *testing.T) {
	c := newTestConsumer(Tag("hello"))

	if c.tag != "hello" {
		t.Error("tag should be set to `hello`")
	}
}

func newTestConsumer(opts ...ConsumerOpt) *Consumer {
	q := &Queue{}