diff --git a/ees/nats_it_test.go b/ees/nats_it_test.go index 5fda90565..f1a5287ce 100644 --- a/ees/nats_it_test.go +++ b/ees/nats_it_test.go @@ -68,8 +68,8 @@ func TestNatsEEJetStream(t *testing.T) { t.Fatal(err) } for name := range js.StreamNames() { - if name == "test" { - if err = js.DeleteStream("test"); err != nil { + if name == "test2" { + if err = js.DeleteStream("test2"); err != nil { t.Fatal(err) } break @@ -77,13 +77,13 @@ func TestNatsEEJetStream(t *testing.T) { } if _, err = js.AddStream(&nats.StreamConfig{ - Name: "test", + Name: "test2", Subjects: []string{"processed_cdrs"}, }); err != nil { t.Fatal(err) } - if err = js.PurgeStream("test"); err != nil { + if err = js.PurgeStream("test2"); err != nil { t.Fatal(err) }