From dac9add5fb49c8b3550f86253793f1ac2652ec56 Mon Sep 17 00:00:00 2001 From: Sinh Date: Tue, 18 Oct 2022 11:55:33 +0700 Subject: [PATCH] add queue subscribe json encoder --- json_encoder.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/json_encoder.go b/json_encoder.go index af13573..c0bde64 100644 --- a/json_encoder.go +++ b/json_encoder.go @@ -22,6 +22,17 @@ func (e JSONEncoder) Subscribe(subject string, cb nats.Handler) (*nats.Subscript return sub, err } +// QueueSubscribe ... +func (e JSONEncoder) QueueSubscribe(subject, queue string, cb nats.Handler) (*nats.Subscription, error) { + sub, err := e.encConn.QueueSubscribe(subject, queue, cb) + if err != nil { + log.Printf("natsio.JSONEncoder.QueueSubscribe err: %v\n", err) + } else { + log.Printf("natsio.JSONEncoder.QueueSubscribe - subscribed to subject %s successfully\n", subject) + } + return sub, err +} + // Publish ... func (e JSONEncoder) Publish(reply string, data interface{}) error { return e.encConn.Publish(reply, data)