mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
Added check on publish error.
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
@@ -18,6 +18,7 @@ package server
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"strings"
|
||||
"testing"
|
||||
"time"
|
||||
@@ -163,7 +164,8 @@ func TestJetStreamClusterDiscardNewAndMaxMsgsPerSubject(t *testing.T) {
|
||||
require_NoError(t, err)
|
||||
|
||||
_, err = js.Publish("KV.foo", nil)
|
||||
require_Error(t, err)
|
||||
// Go client does not have const for this one.
|
||||
require_Error(t, err, errors.New("nats: maximum messages per subject exceeded"))
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user