diff --git a/src/PostalRegistry.Producer.Snapshot.Oslo/ProducerProjections.cs b/src/PostalRegistry.Producer.Snapshot.Oslo/ProducerProjections.cs index a4e6b968..bb709474 100644 --- a/src/PostalRegistry.Producer.Snapshot.Oslo/ProducerProjections.cs +++ b/src/PostalRegistry.Producer.Snapshot.Oslo/ProducerProjections.cs @@ -127,7 +127,7 @@ private async Task Produce( long storePosition, CancellationToken cancellationToken = default) { - var result = await _producer.ProduceJsonMessage( + var result = await _producer.Produce( new MessageKey(objectId), jsonContent, new List { new MessageHeader(MessageHeader.IdempotenceKey, storePosition.ToString()) },