Method QueueSubscribeReply

core/services/messaging/client.go:252–264

QueueSubscribeReply creates a queue subscription that supports replying to requests. Load-balanced across subscribers in the same queue group, with request-reply support.

(subject, queue string, handler func(data []byte, reply func([]byte)))

// QueueSubscribeReply creates a queue subscription that supports replying to requests.
// Load-balanced across subscribers in the same queue group, with request-reply support.
func (c *Client) QueueSubscribeReply(subject, queue string, handler func(data []byte, reply func([]byte))) (Subscription, error) {
	return c.confirmSubscription(subject, func(conn *nats.Conn) (*nats.Subscription, error) {
		return conn.QueueSubscribe(subject, queue, func(msg *nats.Msg) {
			handler(msg.Data, func(replyData []byte) {
				if msg.Reply != "" {
					if err := msg.Respond(replyData); err != nil {
						xlog.Warn("Failed to send NATS reply", "subject", subject, "error", err)
					}
				}
			})
		})
	})
}

// SubscribeJSON creates a subscription that automatically unmarshals JSON messages.
// Invalid JSON messages are logged and skipped.