Method SubscribeReply

core/services/messaging/client.go:236–248

SubscribeReply creates a subscription that supports replying to requests. The handler receives the raw request data and the reply subject.

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

// SubscribeReply creates a subscription that supports replying to requests.
// The handler receives the raw request data and the reply subject.
func (c *Client) SubscribeReply(subject string, handler func(data []byte, reply func([]byte))) (Subscription, error) {
	return c.confirmSubscription(subject, func(conn *nats.Conn) (*nats.Subscription, error) {
		return conn.Subscribe(subject, 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)
					}
				}
			})
		})
	})
}

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