diff --git a/server/jetstream_cluster_3_test.go b/server/jetstream_cluster_3_test.go index cb649da1..9fec4764 100644 --- a/server/jetstream_cluster_3_test.go +++ b/server/jetstream_cluster_3_test.go @@ -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")) }) } }