From e4a24f31cbcb8b780e34130d0438d271b31bc17d Mon Sep 17 00:00:00 2001
From: Alex Shorsher <alex.shorsher@kaleido.io>
Date: Fri, 1 Nov 2024 15:23:34 -0400
Subject: [PATCH] add message state on conflict error

---
 internal/batch/batch_processor.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/batch/batch_processor.go b/internal/batch/batch_processor.go
index 34076934d..a708c6d55 100644
--- a/internal/batch/batch_processor.go
+++ b/internal/batch/batch_processor.go
@@ -636,6 +636,7 @@ func (bp *batchProcessor) dispatchBatch(payload *DispatchPayload) error {
 				conflictErr, conflictTestOk := err.(operations.ConflictError)
 				if conflictTestOk && conflictErr.IsConflictError() {
 					// We know that the connector has received our batch, so we shouldn't need to retry
+					payload.addMessageUpdate(payload.Messages, core.MessageStateReady, core.MessageStateSent)
 					return true, nil
 				}
 			} else {