diff --git a/jserrors.go b/jserrors.go index 977094ffe..1e21249bb 100644 --- a/jserrors.go +++ b/jserrors.go @@ -101,7 +101,7 @@ var ( // ErrRequireServerVersion is returned when using a feature which requires a higher server version. ErrRequireServerVersion JetStreamError = &jsError{message: "invalid server version"} - // ErrConsumerNameMismtch is returned user provides both consumer name and durable name and they are not equal. + // ErrConsumerNameMismatch is returned user provides both consumer name and durable name and they are not equal. ErrConsumerNameMismatch JetStreamError = &jsError{message: "consumer name and durable name do not match"} // DEPRECATED: ErrInvalidDurableName is no longer returned and will be removed in future releases. diff --git a/jsm.go b/jsm.go index 8ed8f7946..55208dce0 100644 --- a/jsm.go +++ b/jsm.go @@ -266,7 +266,7 @@ func (js *js) AddConsumer(stream string, cfg *ConsumerConfig, opts ...JSOpt) (*C return nil, fmt.Errorf("%w: %s", ErrRequireServerVersion, "consumer name requires at least server version 2.9.0") } if cfg.Name != _EMPTY_ && cfg.Durable != _EMPTY_ && cfg.Name != cfg.Durable { - return nil, ErrConsumerNameMismtch + return nil, ErrConsumerNameMismatch } consumerName := cfg.Name if consumerName == _EMPTY_ { @@ -297,7 +297,7 @@ func (js *js) UpdateConsumer(stream string, cfg *ConsumerConfig, opts ...JSOpt) return nil, fmt.Errorf("%w: %s", ErrRequireServerVersion, "consumer name requires at least server version 2.9.0") } if cfg.Name != _EMPTY_ && cfg.Durable != _EMPTY_ && cfg.Name != cfg.Durable { - return nil, ErrConsumerNameMismtch + return nil, ErrConsumerNameMismatch } consumerName := cfg.Name if consumerName == _EMPTY_ { diff --git a/test/js_test.go b/test/js_test.go index 7ea1de830..22eba19de 100644 --- a/test/js_test.go +++ b/test/js_test.go @@ -1460,7 +1460,7 @@ func TestJetStreamManagement(t *testing.T) { }) t.Run("with different Durable and Name set", func(t *testing.T) { - if _, err = js.AddConsumer("foo", &nats.ConsumerConfig{Name: "abc", Durable: "123"}); err != nats.ErrConsumerNameMismtch { + if _, err = js.AddConsumer("foo", &nats.ConsumerConfig{Name: "abc", Durable: "123"}); err != nats.ErrConsumerNameMismatch { t.Fatalf("Expected: %v; got: %v", nats.ErrInvalidConsumerName, err) } })