Skip to content

Commit 73a95fc

Browse files
committed
chore: update Foundatio package versions to 13.0.1-preview.0.12 and add new tests for message bus and queue functionality
1 parent 15ffde7 commit 73a95fc

4 files changed

Lines changed: 68 additions & 2 deletions

File tree

src/Foundatio.AzureServiceBus/Foundatio.AzureServiceBus.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
<PackageReference Include="Azure.Messaging.ServiceBus" Version="7.20.1" />
55
<PackageReference Include="Azure.Identity" Version="1.21.0" />
66

7-
<PackageReference Include="Foundatio" Version="13.0.1-preview.0.11" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
7+
<PackageReference Include="Foundatio" Version="13.0.1-preview.0.12" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
88
<ProjectReference Include="..\..\..\Foundatio\src\Foundatio\Foundatio.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
99
</ItemGroup>
1010
</Project>

tests/Directory.Build.props

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
<PackageReference Include="xunit.runner.visualstudio" Version="3.1.5" />
1313
<PackageReference Include="GitHubActionsTestLogger" Version="3.0.4" PrivateAssets="All" />
1414

15-
<PackageReference Include="Foundatio.TestHarness" Version="13.0.1-preview.0.11" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
15+
<PackageReference Include="Foundatio.TestHarness" Version="13.0.1-preview.0.12" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
1616
<ProjectReference Include="..\..\..\Foundatio\src\Foundatio.TestHarness\Foundatio.TestHarness.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
1717
</ItemGroup>
1818
</Project>

tests/Foundatio.AzureServiceBus.Tests/Messaging/AzureServiceBusMessageBusTests.cs

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -254,6 +254,12 @@ public override Task PublishAsync_WithCancellation_ThrowsOperationCanceledExcept
254254
return base.PublishAsync_WithCancellation_ThrowsOperationCanceledExceptionAsync();
255255
}
256256

257+
[Fact]
258+
public override Task PublishAsync_WithDeliveryDelayExtension_DelaysDeliveryAsync()
259+
{
260+
return base.PublishAsync_WithDeliveryDelayExtension_DelaysDeliveryAsync();
261+
}
262+
257263
[Fact]
258264
public override Task PublishAsync_WithDelayedMessageAndDisposeBeforeDelivery_DiscardsMessageAsync()
259265
{
@@ -266,6 +272,12 @@ public override Task PublishAsync_WithSerializationFailure_ThrowsSerializerExcep
266272
return base.PublishAsync_WithSerializationFailure_ThrowsSerializerExceptionAsync();
267273
}
268274

275+
[Fact]
276+
public override Task PublishAsync_WithUniqueId_PropagatesUniqueIdToSubscriberAsync()
277+
{
278+
return base.PublishAsync_WithUniqueId_PropagatesUniqueIdToSubscriberAsync();
279+
}
280+
269281
[Fact]
270282
public override Task SubscribeAsync_AfterDispose_ThrowsMessageBusExceptionAsync()
271283
{
@@ -278,12 +290,24 @@ public override Task SubscribeAsync_CancelledToken_DoesNotTearDownInfrastructure
278290
return base.SubscribeAsync_CancelledToken_DoesNotTearDownInfrastructureAsync();
279291
}
280292

293+
[Fact]
294+
public override Task SubscribeAsync_ToRawIMessage_CanAccessAllPropertiesAsync()
295+
{
296+
return base.SubscribeAsync_ToRawIMessage_CanAccessAllPropertiesAsync();
297+
}
298+
281299
[Fact]
282300
public override Task SubscribeAsync_WithCancellation_ThrowsOperationCanceledExceptionAsync()
283301
{
284302
return base.SubscribeAsync_WithCancellation_ThrowsOperationCanceledExceptionAsync();
285303
}
286304

305+
[Fact]
306+
public override Task SubscribeAsync_WithCancellationTokenHandler_ReceivesCancellationTokenAsync()
307+
{
308+
return base.SubscribeAsync_WithCancellationTokenHandler_ReceivesCancellationTokenAsync();
309+
}
310+
287311
[Fact]
288312
public override Task SubscribeAsync_WithDeserializationFailure_SkipsMessageAsync()
289313
{

tests/Foundatio.AzureServiceBus.Tests/Queues/AzureServiceBusQueueTests.cs

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,6 +242,12 @@ public override Task DequeueAsync_AfterAbandonWithMutatedValue_ReturnsOriginalVa
242242
return base.DequeueAsync_AfterAbandonWithMutatedValue_ReturnsOriginalValueAsync();
243243
}
244244

245+
[Fact]
246+
public override Task DequeueAsync_WithDispose_AutoAbandonsEntryAsync()
247+
{
248+
return base.DequeueAsync_WithDispose_AutoAbandonsEntryAsync();
249+
}
250+
245251
[Fact]
246252
public override async Task DequeueAsync_WithPoisonMessage_MovesToDeadletterAsync()
247253
{
@@ -318,12 +324,48 @@ public override Task EnqueueAsync_WithSerializationError_ThrowsAndLeavesQueueEmp
318324
return base.EnqueueAsync_WithSerializationError_ThrowsAndLeavesQueueEmptyAsync();
319325
}
320326

327+
[Fact]
328+
public override Task EnqueueAsync_WithUniqueId_UsesProvidedIdAsync()
329+
{
330+
return base.EnqueueAsync_WithUniqueId_UsesProvidedIdAsync();
331+
}
332+
333+
[Fact]
334+
public override Task GetDeadletterItemsAsync_WithDeadletteredEntry_ReturnsItemsAsync()
335+
{
336+
return base.GetDeadletterItemsAsync_WithDeadletteredEntry_ReturnsItemsAsync();
337+
}
338+
339+
[Fact]
340+
public override Task GetQueueActivity_AfterEnqueueAndDequeue_ReturnsTimestampsAsync()
341+
{
342+
return base.GetQueueActivity_AfterEnqueueAndDequeue_ReturnsTimestampsAsync();
343+
}
344+
345+
[Fact]
346+
public override Task GetQueueEntryMetadata_AfterDequeue_ReturnsValidTimestampsAsync()
347+
{
348+
return base.GetQueueEntryMetadata_AfterDequeue_ReturnsValidTimestampsAsync();
349+
}
350+
321351
[Fact]
322352
public override Task MaintainJobNotAbandon_NotWorkTimeOutEntry()
323353
{
324354
return base.MaintainJobNotAbandon_NotWorkTimeOutEntry();
325355
}
326356

357+
[Fact]
358+
public override Task QueueEntry_EntryType_ReturnsCorrectTypeAsync()
359+
{
360+
return base.QueueEntry_EntryType_ReturnsCorrectTypeAsync();
361+
}
362+
363+
[Fact]
364+
public override Task QueueEntry_GetValue_ReturnsUntypedValueAsync()
365+
{
366+
return base.QueueEntry_GetValue_ReturnsUntypedValueAsync();
367+
}
368+
327369
[Fact]
328370
public override Task VerifyDelayedRetryAttemptsAsync()
329371
{

0 commit comments

Comments
 (0)