gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 11:04:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fix test that did not set ack policy to explicit

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-05-06 15:10:46 -07:00
parent caa262513d
commit 18244ea8cb
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server/jetstream_test.go
View File

@@ -19637,6 +19637,7 @@ func TestJetStreamConsumerMultipleSubjectsWithAddedMessages(t *testing.T) {
DeliverSubject: "deliver",
FilterSubjects: []string{"events.created", "events.processed"},
Durable: durable,
AckPolicy: AckExplicit,
})
require_NoError(t, err)
@@ -19682,14 +19683,14 @@ func TestJetStreamConsumerMultipleSubjectsWithAddedMessages(t *testing.T) {
}
}
info, err := js.ConsumerInfo("deliver", durable)
require_NoError(t, err)
require_True(t, info.Delivered.Consumer == 12)
require_True(t, info.Delivered.Stream == 15)
require_True(t, info.AckFloor.Stream == 15)
require_True(t, info.AckFloor.Consumer == 12)
require_True(t, info.AckFloor.Stream == 12)
require_True(t, info.AckFloor.Consumer == 10)
}
func TestJetStreamConsumerThreeFilters(t *testing.T) {