2022-07-31 01:39:37 +04:30

36 lines
970 B
C#

using System.Reflection;
namespace BuildingBlocks.PersistMessageProcessor;
public class PersistMessage
{
public PersistMessage(long id, string dataType, string data, MessageDeliveryType deliveryType)
{
Id = id;
DataType = dataType;
Data = data;
DeliveryType = deliveryType;
Created = DateTime.Now;
MessageStatus = MessageStatus.InProgress;
RetryCount = 0;
}
public long Id { get; private set; }
public string DataType { get; private set; }
public string Data { get; private set; }
public DateTime Created { get; private set; }
public int RetryCount { get; private set; }
public MessageStatus MessageStatus { get; private set; }
public MessageDeliveryType DeliveryType { get; private set; }
public void ChangeState(MessageStatus messageStatus)
{
MessageStatus = messageStatus;
}
public void IncreaseRetry()
{
RetryCount++;
}
}