We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 11b73c2 commit 957cc9bCopy full SHA for 957cc9b
1 file changed
test/ActiveMQ.Artemis.Client.IntegrationTests/ScheduledDeliverySpec.cs
@@ -42,10 +42,10 @@ await producer.SendAsync(new Message("foo")
42
{
43
ScheduledDeliveryDelay = TimeSpan.FromMilliseconds(400)
44
});
45
- await Assert.ThrowsAsync<OperationCanceledException>(async () => await consumer.ReceiveAsync(new CancellationTokenSource(TimeSpan.FromMilliseconds(200)).Token));
46
47
var msg = await consumer.ReceiveAsync();
48
- Assert.Equal("foo", msg.GetBody<string>());
+ var delay = DateTime.UtcNow - msg.CreationTime;
+ Assert.True(delay > msg.ScheduledDeliveryDelay);
49
}
50
51
[Fact]
0 commit comments