Estou tentando criar um exemplo de aplicação que possa fazer a chamada de uma função/método e que após um determinado tempo ele verifique se o processo já foi executado, se não, chama novamente a mesma função/método e verificar o andamento anterior se esta sendo executado ou se já acabou e devolver o retorno do processo.
Já procurei bastante, mas o não encontrei um exemplo que possa ser seguido. Os links abaixo descrevem o que realmente o Design Patterns - Idempotency Messages faz.
https://msdn.microsoft.com/pt-br/library/dn589781.aspx
http://blog.jonathanoliver.com/idempotency-patterns/
Estou tentando da seguinte forma;
using System;
namespace Idempotent_Messages
{
public class Program
{
static IdePotencyHelper idePotencyHelper = new IdePotencyHelper();
public static int passo = 1;
static void Main(string[] args)
{
var func = new Funcionario();
var command = new CqrsBase<Int32, Funcionario>();
command.Execute(func);
command.IdPotency((f) =>
{
var funcBanco = new Funcionario();
funcBanco.Id = 1;
return f.Id == funcBanco.Id;
},
(x)=> { return x.Id; }
, func);
}
}
public class Funcionario
{
public int Id { get; set; }
}
public class CqrsBase<T, TArgs>
{
public T Execute(TArgs args)
{
return default(T);
}
}
public static class CqrsBase
{
public static TReturn IdPotency<TReturn, TArgs>(this CqrsBase<TReturn, TArgs> cqrs, Func<TArgs,bool> verify, Func<TArgs, TReturn> existsFunc, TArgs args)
{
var existe = verify(args);
if (existe)
{
return existsFunc(args);
}
else
{
return cqrs.Execute(args);
}
}
}
}
O Design Patterns - Idempotency
Uma operação é idempotente caso não tenha efeitos adicionais se for chamado mais de uma vez com os mesmos parâmetros. Você não pode controlar como sua API pública é chamada por seus clientes, então você deve se certificar de que não leva a nenhum efeito indesejado se eles repetem suas chamadas uma e outra vez.
Uma solução comum é fornecer uma ID de correlação para qualquer operação potencialmente alterada pelo estado. O serviço verifica em algum repositório se a solicitação foi processada. Se sim, a resposta previamente armazenada deve ser fornecida.
Aqui está um fluxograma que mostra a comunicação com uma identificação de correlação:
O problema é que não sei como fazer para criar um identificador para cada processo armazenar seu status e após o tempo determinador verificar o processo pelo identificador.