func()

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
}