Function TestNoLocal

consumer_test.go:295–301

(t *testing.T)

}

func TestNoLocal(t *testing.T) {
	c := newTestConsumer(NoLocal())

	if !c.noLocal {
		t.Error("noLocal should be set")
	}
}

func TestQos(t *testing.T) {
	c := newTestConsumer(Qos(10))