func ensureQueue(ctx context.Context, ns *servicebus.Namespace, queueName string) (*servicebus.QueueEntity, error) {
	manager := ns.NewQueueManager()
	_, err := manager.Get(ctx, queueName)
	if err == nil {
		_ = manager.Delete(ctx, queueName)
	} else {
		if !servicebus.IsErrNotFound(err) {
			return nil, err
		}
	}
	log.Infof("Creating queue %s", queueName)
	return manager.Put(ctx, queueName)
}
// Ensure each queue for testing is newly created
Ensure each queue for testing is newly created
// Ensure each queue for testing is newly created
func ensureQueue(ctx context.Context, ns *servicebus.Namespace, queueName string) (*servicebus.QueueEntity, error) {
	manager := ns.NewQueueManager()
	_, err := manager.Get(ctx, queueName)
	if err == nil {
		_ = manager.Delete(ctx, queueName)
	} else {
		if !servicebus.IsErrNotFound(err) {
			return nil, err
		}
	}
	log.Infof("Creating queue %s", queueName)
	return manager.Put(ctx, queueName)
}
func ensureQueue ( ctx context . Context , ns * servicebus . Namespace , queueName string ) ( * servicebus . QueueEntity , error ) { manager := ns . NewQueueManager ( ) _ , err := manager . Get ( ctx , queueName ) if err == nil { _ = manager . Delete ( ctx , queueName ) } else { if ! servicebus . IsErrNotFound ( err ) { return nil , err } } log . Infof ( " " , queueName ) return manager . Put ( ctx , queueName ) }
Ensure each queue for testing is newly created
Ensure each queue for testing is newly created