From 56604b801586fe144a1f7be0ed60fa3e2e9918a9 Mon Sep 17 00:00:00 2001 From: Tim Salva Date: Wed, 20 Nov 2024 22:18:09 +0000 Subject: [PATCH] [Bug] Omit item from DynamoDb Delivered index when undelivered --- src/Paramore.Brighter.Outbox.DynamoDB/MessageItem.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Paramore.Brighter.Outbox.DynamoDB/MessageItem.cs b/src/Paramore.Brighter.Outbox.DynamoDB/MessageItem.cs index 5c1c6df7d3..88a5e2b6d8 100644 --- a/src/Paramore.Brighter.Outbox.DynamoDB/MessageItem.cs +++ b/src/Paramore.Brighter.Outbox.DynamoDB/MessageItem.cs @@ -63,7 +63,7 @@ public class MessageItem /// [DynamoDBGlobalSecondaryIndexRangeKey(indexName: "Delivered")] [DynamoDBProperty] - public long DeliveryTime { get; set; } + public long? DeliveryTime { get; set; } /// /// A JSON object representing a dictionary of additional properties set on the message @@ -130,7 +130,7 @@ public MessageItem(Message message, int shard = 0, long? expiresAt = null) CreatedAt = date.ToString("yyyy-MM-ddTHH:mm:ss.fffZ"); 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();