Merge branch 'nondurable_consumer' into nondurable_consumer_0_10_0

dinghram · Apr 3, 2023 · a80d890 · a80d890
2 parents 06b7c26 + 179e020
commit a80d890
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pulsar/consumer_test.go b/pulsar/consumer_test.go
@@ -4095,7 +4095,7 @@ func TestConsumerNonDurable(t *testing.T) {
 		Topic:            topicName,
 		SubscriptionName: "sub-1",
 		Type:             Shared,
-		SubscrptionMode:  NonDurable,
+		SubscriptionMode: NonDurable,
 	})
 	assert.Nil(t, err)
 
@@ -4129,7 +4129,7 @@ func TestConsumerNonDurable(t *testing.T) {
 		Topic:            topicName,
 		SubscriptionName: "sub-1",
 		Type:             Shared,
-		SubscrptionMode:  NonDurable,
+		SubscriptionMode: NonDurable,
 	})
 	assert.Nil(t, err)
 	defer consumer.Close()
@@ -4140,7 +4140,7 @@ func TestConsumerNonDurable(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	msg, err := consumer.Receive(ctx)
+	msg, err = consumer.Receive(ctx)
 	assert.Nil(t, err)
 	assert.Equal(t, fmt.Sprintf("msg-content-%d", i), string(msg.Payload()))
 	consumer.Ack(msg)