@@ -476,7 +476,6 @@ public async Task CrossEntityTransactionReceivesFirst(bool partitioned, bool ena
476476 }
477477
478478 [ Test ]
479- [ Ignore ( "Send claims are not available for the topic. Leaving for now in case this is supported in the future." ) ]
480479 public async Task CrossEntityTransactionReceivesFirstRollbackSubscription ( )
481480 {
482481 await using var client = CreateCrossEntityTxnClient ( ) ;
@@ -497,7 +496,6 @@ public async Task CrossEntityTransactionReceivesFirstRollbackSubscription()
497496 using ( var ts = new TransactionScope ( TransactionScopeAsyncFlowOption . Enabled ) )
498497 {
499498 await receiverA . CompleteMessageAsync ( receivedMessage ) ;
500- // claims exception thrown here
501499 await senderB . SendMessageAsync ( message ) ;
502500 await senderC . SendMessageAsync ( message ) ;
503501 }
@@ -508,12 +506,12 @@ public async Task CrossEntityTransactionReceivesFirstRollbackSubscription()
508506 Assert . IsNotNull ( receivedMessage ) ;
509507 await receiverA . AbandonMessageAsync ( receivedMessage ) ;
510508
511- var receiverB = client . CreateReceiver ( queueB . QueueName ) ;
509+ var receiverB = noTxClient . CreateReceiver ( queueB . QueueName ) ;
512510
513511 receivedMessage = await receiverB . ReceiveMessageAsync ( TimeSpan . FromSeconds ( 10 ) ) ;
514512 Assert . IsNull ( receivedMessage ) ;
515513
516- var receiverC = client . CreateReceiver ( queueC . QueueName ) ;
514+ var receiverC = noTxClient . CreateReceiver ( queueC . QueueName ) ;
517515 receivedMessage = await receiverC . ReceiveMessageAsync ( TimeSpan . FromSeconds ( 10 ) ) ;
518516 Assert . IsNull ( receivedMessage ) ;
519517
0 commit comments