Skip to content

Commit 9ebfe25

Browse files
Fix message state tests (Azure#25520)
1 parent 5e83d87 commit 9ebfe25

File tree

3 files changed

+10
-6
lines changed

3 files changed

+10
-6
lines changed

sdk/servicebus/Azure.Messaging.ServiceBus/src/Primitives/ServiceBusReceivedMessage.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -425,7 +425,7 @@ public ServiceBusMessageState State
425425
return (ServiceBusMessageState)val;
426426
}
427427

428-
return default;
428+
return ServiceBusMessageState.Active;
429429
}
430430
internal set
431431
{

sdk/servicebus/Azure.Messaging.ServiceBus/tests/Message/MessageLiveTests.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -204,6 +204,10 @@ public async Task CreateFromReceivedMessageCopiesPropertiesTopic()
204204

205205
ServiceBusSessionReceiver receiver = await client.AcceptNextSessionAsync(scope.TopicName, scope.SubscriptionNames.First());
206206
ServiceBusReceivedMessage received = await receiver.ReceiveMessageAsync();
207+
208+
// defer the message so we can verify that the Message State is cleared as expected by constructor
209+
await receiver.DeferMessageAsync(received);
210+
received = await receiver.PeekMessageAsync();
207211
AmqpAnnotatedMessage rawReceived = received.GetRawAmqpMessage();
208212
Assert.IsNotNull(rawReceived.Header.DeliveryCount);
209213
Assert.IsTrue(rawReceived.MessageAnnotations.ContainsKey(AmqpMessageConstants.LockedUntilName));

sdk/servicebus/Azure.Messaging.ServiceBus/tests/Receiver/ReceiverLiveTests.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -490,7 +490,7 @@ public async Task DeferMessagesList()
490490
{
491491
Assert.AreEqual(messageList[i].MessageId, deferredMessages[i].MessageId);
492492
Assert.AreEqual(messageList[i].Body.ToArray(), deferredMessages[i].Body.ToArray());
493-
Assert.AreEqual(ServiceBusMessageState.Deferred, deferredMessages[i]);
493+
Assert.AreEqual(ServiceBusMessageState.Deferred, deferredMessages[i].State);
494494
}
495495

496496
// verify that looking up a non-existent sequence number will throw
@@ -545,7 +545,7 @@ public async Task DeferMessagesArray()
545545
{
546546
Assert.AreEqual(messageList[i].MessageId, deferredMessages[i].MessageId);
547547
Assert.AreEqual(messageList[i].Body.ToArray(), deferredMessages[i].Body.ToArray());
548-
Assert.AreEqual(ServiceBusMessageState.Deferred, deferredMessages[i]);
548+
Assert.AreEqual(ServiceBusMessageState.Deferred, deferredMessages[i].State);
549549
}
550550

551551
// verify that an empty array can be passed
@@ -602,7 +602,7 @@ IEnumerable<long> GetEnumerable()
602602
{
603603
Assert.AreEqual(messageList[i].MessageId, deferredMessages[i].MessageId);
604604
Assert.AreEqual(messageList[i].Body.ToArray(), deferredMessages[i].Body.ToArray());
605-
Assert.AreEqual(ServiceBusMessageState.Deferred, deferredMessages[i]);
605+
Assert.AreEqual(ServiceBusMessageState.Deferred, deferredMessages[i].State);
606606
}
607607

608608
// verify that an empty enumerable can be passed
@@ -629,12 +629,12 @@ public async Task CanPeekADeferredMessage()
629629
var peekedMsg = await receiver.PeekMessageAsync();
630630
Assert.AreEqual(receivedMsg.MessageId, peekedMsg.MessageId);
631631
Assert.AreEqual(receivedMsg.SequenceNumber, peekedMsg.SequenceNumber);
632-
Assert.AreEqual(ServiceBusMessageState.Deferred, receivedMsg.State);
632+
Assert.AreEqual(ServiceBusMessageState.Deferred, peekedMsg.State);
633633

634634
var deferredMsg = await receiver.ReceiveDeferredMessageAsync(peekedMsg.SequenceNumber);
635635
Assert.AreEqual(peekedMsg.MessageId, deferredMsg.MessageId);
636636
Assert.AreEqual(peekedMsg.SequenceNumber, deferredMsg.SequenceNumber);
637-
Assert.AreEqual(peekedMsg.State, receivedMsg.State);
637+
Assert.AreEqual(peekedMsg.State, deferredMsg.State);
638638
}
639639
}
640640

0 commit comments

Comments
 (0)