Below is the error encountered recently
Below is Code for EmailJob.Run()
public class EmailJob
{
public void Run()
{
using (var connection = SqlConnections.NewFor<MailRow>())
{
var m = MailRow.Fields;
var config = Config.Get<MailingServiceSettings>();
var mailList = connection.List<MailRow>(q => q
.Take(config.BatchSize)
.Select(m.MailId)
.Select(m.LockExpiration)
.Where(
m.Status == (int)MailStatus.InQueue &
m.RetryCount < config.RetryLimit &
m.LockExpiration < DateTime.Now)
.OrderBy(m.Priority)
.OrderBy(m.RetryCount)
.OrderBy(m.MailId));
var lockDuration = TimeSpan.FromSeconds(config.LockDuration);
foreach (var mail in mailList)
{
try
{
using (var uow = new UnitOfWork(connection))
{
if (new SqlUpdate(m.TableName)
.Set(m.LockExpiration, DateTime.Now.Add(lockDuration))
.Where(
m.MailId == mail.MailId.Value)
.Execute(connection, ExpectedRows.ZeroOrOne) == 1)
{
uow.Commit();
}
else
continue;
}
new MailingService().SendById(connection, mail.MailId.Value);
}
catch (Exception ex)
{
ex.Log();
}
}
}
}
}
Below is the startup.cs calling recurring jobs:
RecurringJob.AddOrUpdate<ServicesProject.Web.Modules.Common.Jobs.EmailJob>(job => job.Run(), “0 */2 * ? * *”);
Packages and version used:
Please help to fix this!