Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Fix backwards compatibilyt
  • Loading branch information
tomas-pajurek committed Jul 10, 2025
commit 9a7fdeeb3dc0cabb91263f3176bdd1969fbd2507
Original file line number Diff line number Diff line change
Expand Up @@ -218,11 +218,13 @@ private async Task<IEnumerable<EventData>> ReceiveBatchCoreAsync(int maximumEven
}
else
{
#pragma warning disable CS0618 // Type or member is obsolete
_lastEnqueuedEventProperties = new(
partitionProperties.LastEnqueuedSequenceNumber,
lastOffsetString: partitionProperties.LastEnqueuedOffsetString,
lastOffset: partitionProperties.LastEnqueuedOffset,
partitionProperties.LastEnqueuedTime,
_timeProvider.GetUtcNow());
#pragma warning restore CS0618 // Type or member is obsolete
}
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,14 +72,18 @@ public PartitionProperties GetProperties()

var beginningSequenceNumber = currentSegment.Count > 0 ? currentSegment[0].SequenceNumber : lastSequenceNumber;

#pragma warning disable CS0618 // Type or member is obsolete

return EventHubsModelFactory.PartitionProperties(
eventHubName: name,
partitionId: PartitionId,
isEmpty: currentSegment.Count is 0,
beginningSequenceNumber: beginningSequenceNumber,
lastSequenceNumber: _lastSequenceNumber,
lastOffsetString: _lastOffset.ToString(),
lastOffset: _lastOffset,
lastEnqueuedTime: _lastEnqueuedTime);

#pragma warning restore CS0618 // Type or member is obsolete
}

public void SendEvent(EventData eventData, string? partitionKey)
Expand Down Expand Up @@ -114,15 +118,17 @@ public void SendEvent(EventData eventData, string? partitionKey)
var eventDataPropertiesCopy = new Dictionary<string, object>(eventData.Properties);
var eventDataSystemPropertiesCopy = new Dictionary<string, object>(eventData.SystemProperties);

#pragma warning disable CS0618 // Type or member is obsolete
var eventWithSystemProperties = EventHubsModelFactory.EventData(
eventBody: new(eventBodyCopy),
properties: eventDataPropertiesCopy,
systemProperties: eventDataSystemPropertiesCopy,
partitionKey: partitionKey,
sequenceNumber: _lastSequenceNumber,
offsetString: _lastOffset.ToString(),
offset: _lastOffset,
enqueuedTime: _lastEnqueuedTime
);
#pragma warning restore CS0618 // Type or member is obsolete

eventWithSystemProperties.MessageId = eventData.MessageId;
eventWithSystemProperties.CorrelationId = eventData.CorrelationId;
Expand Down
Loading