in v2/health.go [93:109]
func (s *SenderHealthChecker) HealthCheck(ctx context.Context, namespaceName string, client *azservicebus.Client) error {
sbSender, err := client.NewSender(s.EntityName, nil)
defer func() {
if sbSender != nil {
if closeErr := sbSender.Close(ctx); closeErr != nil {
getLogger(ctx).Error(closeErr.Error())
err = closeErr
}
}
s.incHealthCheckMetric(namespaceName, err)
}()
if err != nil {
return err
}
_, err = sbSender.NewMessageBatch(ctx, nil)
return err
}