@@ -476,7 +476,6 @@ public async Task CrossEntityTransactionReceivesFirst(bool partitioned, bool ena
476
476
}
477
477
478
478
[ Test ]
479
- [ Ignore ( "Send claims are not available for the topic. Leaving for now in case this is supported in the future." ) ]
480
479
public async Task CrossEntityTransactionReceivesFirstRollbackSubscription ( )
481
480
{
482
481
await using var client = CreateCrossEntityTxnClient ( ) ;
@@ -497,7 +496,6 @@ public async Task CrossEntityTransactionReceivesFirstRollbackSubscription()
497
496
using ( var ts = new TransactionScope ( TransactionScopeAsyncFlowOption . Enabled ) )
498
497
{
499
498
await receiverA . CompleteMessageAsync ( receivedMessage ) ;
500
- // claims exception thrown here
501
499
await senderB . SendMessageAsync ( message ) ;
502
500
await senderC . SendMessageAsync ( message ) ;
503
501
}
@@ -508,12 +506,12 @@ public async Task CrossEntityTransactionReceivesFirstRollbackSubscription()
508
506
Assert . IsNotNull ( receivedMessage ) ;
509
507
await receiverA . AbandonMessageAsync ( receivedMessage ) ;
510
508
511
- var receiverB = client . CreateReceiver ( queueB . QueueName ) ;
509
+ var receiverB = noTxClient . CreateReceiver ( queueB . QueueName ) ;
512
510
513
511
receivedMessage = await receiverB . ReceiveMessageAsync ( TimeSpan . FromSeconds ( 10 ) ) ;
514
512
Assert . IsNull ( receivedMessage ) ;
515
513
516
- var receiverC = client . CreateReceiver ( queueC . QueueName ) ;
514
+ var receiverC = noTxClient . CreateReceiver ( queueC . QueueName ) ;
517
515
receivedMessage = await receiverC . ReceiveMessageAsync ( TimeSpan . FromSeconds ( 10 ) ) ;
518
516
Assert . IsNull ( receivedMessage ) ;
519
517
0 commit comments