add queue subscribe #47
|
@ -40,6 +40,16 @@ func (sv Server) Subscribe(subject string, cb nats.MsgHandler) (*nats.Subscripti
|
|||
return sub, nil
|
||||
}
|
||||
|
||||
// QueueSubscribe ...
|
||||
func (sv Server) QueueSubscribe(subject, queue string, cb nats.MsgHandler) (*nats.Subscription, error) {
|
||||
sub, err := sv.instance.QueueSubscribe(subject, queue, cb)
|
||||
if err != nil {
|
||||
msg := fmt.Sprintf("[NATS SERVER] - queue subscribe subject %s, queue %s error: %s", subject, queue, err.Error())
|
||||
return nil, errors.New(msg)
|
||||
}
|
||||
return sub, nil
|
||||
}
|
||||
|
||||
// NewJSONEncodedConn ...
|
||||
func (sv Server) NewJSONEncodedConn() (*JSONEncoder, error) {
|
||||
enc, err := nats.NewEncodedConn(sv.instance, nats.JSON_ENCODER)
|
||||
|
|
Loading…
Reference in New Issue