diff --git a/pubsub/jetstream/metadata.go b/pubsub/jetstream/metadata.go index b4d48114b..8bc1f737c 100644 --- a/pubsub/jetstream/metadata.go +++ b/pubsub/jetstream/metadata.go @@ -117,7 +117,6 @@ func parseMetadata(psm pubsub.Metadata) (metadata, error) { if duration, err := time.ParseDuration(trimmed); err == nil { backOff = append(backOff, duration) } - } m.backOff = backOff diff --git a/pubsub/jetstream/metadata_test.go b/pubsub/jetstream/metadata_test.go index e92eb4033..9ee8c8365 100644 --- a/pubsub/jetstream/metadata_test.go +++ b/pubsub/jetstream/metadata_test.go @@ -67,7 +67,7 @@ func TestParseMetadata(t *testing.T) { replicas: 3, memoryStorage: true, rateLimit: 20000, - hearbeat: time.Duration(time.Second * 1), + hearbeat: time.Second * 1, }, expectErr: false, },