While using the Messages() API of a durable consumer, how do I register a callback for permission violation errors?

[debajyoti-truefoundry]

Code Snippet:

	for {
		msg, err := n.messages.Next()
		if err != nil {
			if errors.Is(err, jetstream.ErrMsgIteratorClosed) {
				break
			}
			utils.ErrorLogger.Println(fmt.Errorf("fillSubscriptionBuffer: Error while getting the next msg: %w", err))
			continue
		}
                 ...
	}

Output:

nats: Permissions Violation for Publish to "$JS.API.CONSUMER.MSG.NEXT.redacted.redacted" on connection [35658]
[ERROR] 2024/04/18 11:11:16 nats.go:57: fillSubscriptionBuffer: Error while getting the next msg: nats: no heartbeat received
nats: Permissions Violation for Publish to "$JS.API.CONSUMER.MSG.NEXT.redacted.redacted" on connection [35658]
[ERROR] 2024/04/18 11:12:16 nats.go:57: fillSubscriptionBuffer: Error while getting the next msg: nats: no heartbeat received
nats: Permissions Violation for Publish to "$JS.API.CONSUMER.MSG.NEXT.redacted.redacted" on connection [35658]

I want to define a callback to terminate my application if I get a permission violation while fetching the following message.