mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 03:24:40 -07:00
Fix one more test that did not set ack policy to explicit
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
@@ -19770,6 +19770,7 @@ func TestJetStreamConsumerUpdateFilterSubjects(t *testing.T) {
|
||||
_, err = mset.addConsumer(&ConsumerConfig{
|
||||
FilterSubjects: []string{"events", "data"},
|
||||
Durable: "multi",
|
||||
AckPolicy: AckExplicit,
|
||||
})
|
||||
require_NoError(t, err)
|
||||
|
||||
@@ -19786,6 +19787,7 @@ func TestJetStreamConsumerUpdateFilterSubjects(t *testing.T) {
|
||||
_, err = mset.addConsumer(&ConsumerConfig{
|
||||
FilterSubjects: []string{"events", "data", "other"},
|
||||
Durable: "multi",
|
||||
AckPolicy: AckExplicit,
|
||||
})
|
||||
require_NoError(t, err)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user