diff --git a/jserrors.go b/jserrors.go index 6ef90f6f2..41b50f0b8 100644 --- a/jserrors.go +++ b/jserrors.go @@ -44,7 +44,7 @@ var ( // Client errors - // ErrConsumerNotFound is an error returned when consumer with given name does not exist. + // ErrConsumerNameAlreadyInUse is an error returned when consumer with given name already exists. ErrConsumerNameAlreadyInUse JetStreamError = &jsError{message: "consumer name already in use"} // ErrConsumerNotActive is an error returned when consumer is not active. diff --git a/jsm.go b/jsm.go index 141d6cb15..2e92f9c22 100644 --- a/jsm.go +++ b/jsm.go @@ -94,7 +94,7 @@ type JetStreamManager interface { // AccountInfo retrieves info about the JetStream usage from an account. AccountInfo(opts ...JSOpt) (*AccountInfo, error) - // StreamNameBySubjec rteturns a stream matching given subject. + // StreamNameBySubject returns a stream matching given subject. StreamNameBySubject(string, ...JSOpt) (string, error) }