func()

in v2/health.go [127:144]

• 17 lines of code
• 4 McCabe index (conditional complexity)

func (r *ReceiverHealthChecker) HealthCheck(ctx context.Context, namespaceName string, client *azservicebus.Client) error {
	sbReceiver, err := r.createReceiver(client)
	defer func() {
		if sbReceiver != nil {
			if closeErr := sbReceiver.Close(ctx); closeErr != nil {
				getLogger(ctx).Error(closeErr.Error())
				err = closeErr
			}
		}
		r.incHealthCheckMetric(namespaceName, err)
	}()
	if err != nil {
		return err
	}
	// note: PeekMessages() does not return an error when the entity is empty
	_, err = sbReceiver.PeekMessages(ctx, 1, nil)
	return err
}