Skip to content

Commit

Permalink
[Bug] Omit item from Delivered index when it has not been delivered (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
jtsalva authored Dec 29, 2024
1 parent 6836c11 commit b9ab92c
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/Paramore.Brighter.Outbox.DynamoDB/MessageItem.cs
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public class MessageItem
/// </summary>
[DynamoDBGlobalSecondaryIndexRangeKey(indexName: "Delivered")]
[DynamoDBProperty]
public long DeliveryTime { get; set; }
public long? DeliveryTime { get; set; }

/// <summary>
/// A JSON object representing a dictionary of additional properties set on the message
Expand Down Expand Up @@ -129,7 +129,7 @@ public MessageItem(Message message, int shard = 0, long? expiresAt = null)
CreatedAt = $"{date}";
CreatedTime = date.Ticks;
OutstandingCreatedTime = date.Ticks;
DeliveryTime = 0;
DeliveryTime = null;
HeaderBag = JsonSerializer.Serialize(message.Header.Bag, JsonSerialisationOptions.Options);
MessageId = message.Id.ToString();
MessageType = message.Header.MessageType.ToString();
Expand Down

0 comments on commit b9ab92c

Please sign in to comment.