diff --git a/server_reqres.go b/server_reqres.go index cb50938..c21b4dc 100644 --- a/server_reqres.go +++ b/server_reqres.go @@ -34,3 +34,8 @@ func (sv Server) Subscribe(subject string, cb nats.MsgHandler) (*nats.Subscripti } return sub, nil } + +// NewJSONEncodedConn ... +func (sv Server) NewJSONEncodedConn() (*nats.EncodedConn, error) { + return nats.NewEncodedConn(sv.instance, nats.JSON_ENCODER) +}