Отложите освобождение сообщения до определенного времени, используя RedisMqHost
Можно ли использовать RedisMqServer в качестве простого планировщика задач? Например, чтобы опубликовать сообщение и выполнить его в функции (в определенное время)?
1 ответ
RedisMQ не предоставляет никакой явной поддержки для задержанных сообщений, но вы можете использовать симуляцию с таймером, например:
var sendInMs = 30 * 1000;
new System.Threading.Timer(msg => mqClient.Publish(msg),
msg,
sendInMs,
Timeout.Infinite);