mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
support jetstream client kind in a few places
This commit is contained in:
committed by
Derek Collison
parent
fc6d8826f5
commit
10a419ca3d
@@ -1306,6 +1306,8 @@ func (c *client) processErr(errStr string) {
|
||||
c.Errorf("Leafnode Error %s", errStr)
|
||||
c.leafProcessErr(errStr)
|
||||
close = false
|
||||
case JETSTREAM:
|
||||
c.Errorf("JetStream Error %s", errStr)
|
||||
}
|
||||
if close {
|
||||
c.closeConnection(ParseError)
|
||||
@@ -3503,6 +3505,8 @@ func (c *client) typeString() string {
|
||||
return "Gateway"
|
||||
case LEAF:
|
||||
return "LeafNode"
|
||||
case JETSTREAM:
|
||||
return "JetStream"
|
||||
}
|
||||
return "Unknown Type"
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user