c# - SqlDependency con EntityFramework 6(async)

sqldependency c#

Question

Estoy usando las funciones de consulta async EF 6, como

var list = await cx.Clients.Where(c => c.FirstName.Length > 0).ToListAsync();

También quiero iniciar dependencias SQL en estas consultas para poder recibir notificaciones cuando cambien los datos en la base de datos. Puedo hacer esto usando System.Runtime.Remoting.Messaging.CallContext siguiente manera:

    async Task GetData()
    {
        using (ClientsContext context = new ClientsContext()) // subclass of DbContext
        {

            SqlDependency.Start(context.Database.Connection.ConnectionString);
            SqlDependency dependency = new SqlDependency();
            dependency.OnChange += (sender, e) =>
                {
                    Console.Write(e.ToString()); 
                };

            System.Runtime.Remoting.Messaging.CallContext.SetData("MS.SqlDependencyCookie", dependency.Id);
            var list = await context.Clients.Where(c => c.FirstName.Length > 0).ToListAsync();
        }
    }

.. y funciona bien. Pero me encuentro con un problema si quiero tener una SqlDependency en más de una consulta. Si tengo dos métodos async similares a GetData() anteriores, y ejecuto ambos al mismo tiempo, solo el primero recibirá las notificaciones de cambio. Supongo que esto se debe a que CallContext tiene la cookie establecida por cada método en sucesión. Si espero a que se complete el primer método async , llame al segundo, ambos reciben las notificaciones de cambio como se esperaba. Hay alguna solución para esto?

Answer 1

No estoy muy familiarizado con SqlDependency, pero lo que sigue a continuación permitirá que CallContext tenga el valor correcto en el momento en que se llama a ToListAsync (cuando se ejecutan varias llamadas). Prueba de concepto aquí, https://dotnetfiddle.net/F8FnFe

    async Task<List<Client>> GetData()
    {
        using (ClientsContext context = new ClientsContext()) // subclass of DbContext
        {
            SqlDependency.Start(context.Database.Connection.ConnectionString);
            SqlDependency dependency = new SqlDependency();
            dependency.OnChange += (sender, e) =>
            {
                Console.Write(e.ToString());
            };

            Task<List<Client>> task = Task<Task<List<Client>>>.Factory.StartNew(async () =>
            {
                System.Runtime.Remoting.Messaging.CallContext.SetData("MS.SqlDependencyCookie", dependency.Id);
                var list = await context.Clients.Where(c => c.FirstName.Length > 0).ToListAsync();
            }).Unwrap();

            return await task;
        }
    }