Skip to content
This repository has been archived by the owner on Jul 28, 2021. It is now read-only.

Setting Stream MaxConsumers always fails #269

Closed
ripienaar opened this issue Jul 24, 2020 · 0 comments
Closed

Setting Stream MaxConsumers always fails #269

ripienaar opened this issue Jul 24, 2020 · 0 comments

Comments

@ripienaar
Copy link
Collaborator

func TestJetStreamAddStreamMaxConsumers(t *testing.T) {
	s := RunBasicJetStreamServer()
	defer s.Shutdown()

	if config := s.JetStreamConfig(); config != nil {
		defer os.RemoveAll(config.StoreDir)
	}

	nc := clientConnectToServer(t, s)
	defer nc.Close()

	cfg := &server.StreamConfig{
		Name:         "MAXC",
		Subjects:     []string{"in.maxc.>"},
		MaxConsumers: 1,
	}

	acc := s.GlobalAccount()
	mset, err := acc.AddStream(cfg)
	if err != nil {
		t.Fatalf("Unexpected error adding stream: %v", err)
	}

	if mset.Config().MaxConsumers != 1 {
		t.Fatalf("Expected 1 MaxConsumers, got %d", mset.Config().MaxConsumers)
	}
}

This fails with:

=== RUN   TestJetStreamAddStreamMaxConsumers
    TestJetStreamAddStreamMaxConsumers: jetstream_test.go:722: Unexpected error adding stream: maximum consumers exceeds account limit
--- FAIL: TestJetStreamAddStreamMaxConsumers (0.03s)
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant