Function TestJetStreamSubscribe_SkipConsumerLookup

test/js_test.go:1075–1227

(t *testing.T)

}

func TestJetStreamSubscribe_SkipConsumerLookup(t *testing.T) {
	s := RunBasicJetStreamServer()
	defer shutdownJSServerAndRemoveStorage(t, s)

	nc, js := jsClient(t, s)
	defer nc.Close()
	_, err := js.AddStream(&nats.StreamConfig{
		Name:     "TEST",
		Subjects: []string{"foo"},
	})
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

	_, err = js.AddConsumer("TEST", &nats.ConsumerConfig{
		Name:           "cons",
		DeliverSubject: "_INBOX.foo",
		AckPolicy:      nats.AckExplicitPolicy,
	})
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

	// for checking whether subscribe looks up the consumer
	infoSub, err := nc.SubscribeSync("$JS.API.CONSUMER.INFO.TEST.*")
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}
	defer infoSub.Unsubscribe()

	// for checking whether subscribe creates the consumer
	createConsSub, err := nc.SubscribeSync("$JS.API.CONSUMER.CREATE.>")
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}
	defer createConsSub.Unsubscribe()
	t.Run("use Bind to skip consumer lookup and create", func(t *testing.T) {
		sub, err := js.SubscribeSync("", nats.Bind("TEST", "cons"), nats.SkipConsumerLookup(), nats.DeliverSubject("_INBOX.foo"))
		if err != nil {
			t.Fatalf("Unexpected error: %v", err)
		}
		defer sub.Unsubscribe()
		// we should get timeout waiting for msg on CONSUMER.INFO
		if msg, err := infoSub.NextMsg(50 * time.Millisecond); err == nil {
			t.Fatalf("Expected to skip consumer lookup; got message on %q", msg.Subject)
		}

		// we should get timeout waiting for msg on CONSUMER.CREATE
		if msg, err := createConsSub.NextMsg(50 * time.Millisecond); err == nil {
			t.Fatalf("Expected to skip consumer create; got message on %q", msg.Subject)
		}
		if _, err := js.Publish("foo", []byte("msg")); err != nil {
			t.Fatalf("Unexpected error: %s", err)
		}
		if _, err := sub.NextMsg(100 * time.Millisecond); err != nil {
			t.Fatalf("Expected to receive msg; got: %s", err)
		}
	})