mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
committed by
Derek Collison
parent
670be37646
commit
359a4d980b
@@ -443,7 +443,7 @@ func (mset *stream) addConsumerWithAssignment(config *ConsumerConfig, oname stri
|
||||
}
|
||||
if maxc > 0 && len(mset.consumers) >= maxc {
|
||||
mset.mu.Unlock()
|
||||
return nil, ApiErrors[JSStreamMaximumConsumersReachedErr]
|
||||
return nil, ApiErrors[JSMaximumConsumersLimitErr]
|
||||
}
|
||||
|
||||
// Check on stream type conflicts with WorkQueues.
|
||||
|
||||
@@ -949,16 +949,6 @@
|
||||
"url": "",
|
||||
"deprecates": ""
|
||||
},
|
||||
{
|
||||
"constant": "JSStreamMaximumConsumersReachedErr",
|
||||
"code": 400,
|
||||
"error_code": 10097,
|
||||
"description": "maximum consumers limit reached",
|
||||
"comment": "",
|
||||
"help": "",
|
||||
"url": "",
|
||||
"deprecates": ""
|
||||
},
|
||||
{
|
||||
"constant": "JSConsumerWQRequiresExplicitAckErr",
|
||||
"code": 400,
|
||||
@@ -1049,4 +1039,4 @@
|
||||
"url": "",
|
||||
"deprecates": ""
|
||||
}
|
||||
]
|
||||
]
|
||||
|
||||
@@ -249,9 +249,6 @@ const (
|
||||
// JSStreamLimitsErrF General stream limits exceeded error string ({err})
|
||||
JSStreamLimitsErrF ErrorIdentifier = 10053
|
||||
|
||||
// JSStreamMaximumConsumersReachedErr maximum consumers limit reached
|
||||
JSStreamMaximumConsumersReachedErr ErrorIdentifier = 10097
|
||||
|
||||
// JSStreamMessageExceedsMaximumErr message size exceeds maximum allowed
|
||||
JSStreamMessageExceedsMaximumErr ErrorIdentifier = 10054
|
||||
|
||||
@@ -403,7 +400,6 @@ var (
|
||||
JSStreamInvalidErr: {Code: 500, ErrCode: 10096, Description: "stream not valid"},
|
||||
JSStreamInvalidExternalDeliverySubjErrF: {Code: 400, ErrCode: 10024, Description: "stream external delivery prefix {prefix} must not contain wildcards"},
|
||||
JSStreamLimitsErrF: {Code: 500, ErrCode: 10053, Description: "{err}"},
|
||||
JSStreamMaximumConsumersReachedErr: {Code: 400, ErrCode: 10097, Description: "maximum consumers limit reached"},
|
||||
JSStreamMessageExceedsMaximumErr: {Code: 400, ErrCode: 10054, Description: "message size exceeds maximum allowed"},
|
||||
JSStreamMirrorNotUpdatableErr: {Code: 400, ErrCode: 10055, Description: "Mirror configuration can not be updated"},
|
||||
JSStreamMismatchErr: {Code: 400, ErrCode: 10056, Description: "stream name in subject does not match request"},
|
||||
|
||||
Reference in New Issue
Block a user