Solved integration test error in ees for NATS

This commit is contained in:
nickolasdaniel
2021-07-21 13:42:45 +03:00
committed by Dan Christian Bogos
parent a150a38481
commit 9da84ddac7

View File

@@ -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)
}