1111use MicrosoftAzure \Storage \Queue \Models \CreateMessageResult ;
1212use MicrosoftAzure \Storage \Queue \Models \GetQueueMetadataResult ;
1313use MicrosoftAzure \Storage \Queue \Models \ListMessagesResult ;
14+ use MicrosoftAzure \Storage \Queue \Models \PeekMessagesOptions ;
1415use MicrosoftAzure \Storage \Queue \Models \PeekMessagesResult ;
1516use MicrosoftAzure \Storage \Queue \Models \QueueMessage ;
1617use Neos \Flow \Tests \UnitTestCase ;
2324use Exception ;
2425use ReflectionClass ;
2526
26- class AzureQueueStorageTest extends UnitTestCase
27+ class AzureStorageQueueTest extends UnitTestCase
2728{
2829 protected AzureQueueStorage $ obj ;
2930 protected AzureStorageClientFactory &MockObject $ clientFactory ;
@@ -189,12 +190,15 @@ public function setUpCreatesPriorityQueueWhenEnabled(): void
189190 {
190191 $ queue = $ this ->createQueue ('test-queue ' , ['usePriorityQueue ' => true ]);
191192
192- $ this ->queueService ->expects ($ this ->exactly (2 ))
193+ $ matcher = $ this ->exactly (2 );
194+ $ this ->queueService ->expects ($ matcher )
193195 ->method ('createQueue ' )
194- ->withConsecutive (
195- ['test-queue ' ],
196- ['test-queue-priority ' ]
197- );
196+ ->willReturnCallback (function (string $ queueName ) use ($ matcher ) {
197+ match ($ matcher ->numberOfInvocations ()) {
198+ 1 => $ this ->assertEquals ($ queueName , 'test-queue ' ),
199+ 2 => $ this ->assertEquals ($ queueName , 'test-queue-priority ' ),
200+ };
201+ });
198202
199203 $ queue ->setUp ();
200204 }
@@ -682,11 +686,13 @@ public function peekReturnsMessagesFromBothQueues(): void
682686
683687 $ this ->queueService ->expects ($ this ->exactly (2 ))
684688 ->method ('peekMessages ' )
685- ->withConsecutive (
686- ['test-queue-priority ' , $ this ->anything ()],
687- ['test-queue ' , $ this ->anything ()]
688- )
689- ->willReturnOnConsecutiveCalls ($ highPriorityResult , $ normalResult );
689+ ->willReturnCallback (
690+ fn (string $ queueName , PeekMessagesOptions $ options ) =>
691+ match ($ queueName ) {
692+ 'test-queue-priority ' => $ highPriorityResult ,
693+ 'test-queue ' => $ normalResult ,
694+ }
695+ );
690696
691697 $ messages = $ queue ->peek (2 );
692698
@@ -744,19 +750,23 @@ public function countReadySumsBothQueuesWhenPriorityEnabled(): void
744750
745751 $ this ->queueService ->expects ($ this ->exactly (2 ))
746752 ->method ('peekMessages ' )
747- ->withConsecutive (
748- ['test-queue ' ],
749- ['test-queue-priority ' ]
750- )
751- ->willReturnOnConsecutiveCalls ($ normalMessages , $ priorityMessages );
753+ ->willReturnCallback (
754+ fn ($ queueName ) =>
755+ match ($ queueName ) {
756+ 'test-queue-priority ' => $ priorityMessages ,
757+ 'test-queue ' => $ normalMessages
758+ }
759+ );
752760
753761 $ this ->queueService ->expects ($ this ->exactly (2 ))
754762 ->method ('getQueueMetadata ' )
755- ->withConsecutive (
756- ['test-queue ' ],
757- ['test-queue-priority ' ]
758- )
759- ->willReturnOnConsecutiveCalls ($ normalMetadata , $ priorityMetadata );
763+ ->willReturnCallback (
764+ fn ($ queueName ) =>
765+ match ($ queueName ) {
766+ 'test-queue-priority ' => $ priorityMetadata ,
767+ 'test-queue ' => $ normalMetadata
768+ }
769+ );
760770
761771 $ count = $ queue ->countReady ();
762772
@@ -848,12 +858,15 @@ public function flushClearsBothQueuesWhenPriorityEnabled(): void
848858 {
849859 $ queue = $ this ->createQueue ('test-queue ' , ['usePriorityQueue ' => true ]);
850860
851- $ this ->queueService ->expects ($ this ->exactly (2 ))
861+ $ matcher = $ this ->exactly (2 );
862+ $ this ->queueService ->expects ($ matcher )
852863 ->method ('clearMessages ' )
853- ->withConsecutive (
854- ['test-queue ' ],
855- ['test-queue-priority ' ]
856- );
864+ ->willReturnCallback (function (string $ queueName ) use ($ matcher ) {
865+ match ($ matcher ->numberOfInvocations ()) {
866+ 1 => $ this ->assertEquals ($ queueName , 'test-queue ' ),
867+ 2 => $ this ->assertEquals ($ queueName , 'test-queue-priority ' ),
868+ };
869+ });
857870
858871 $ listBlobsResult = $ this ->createMock (ListBlobsResult::class);
859872 $ listBlobsResult ->method ('getBlobs ' )->willReturn ([]);
@@ -872,12 +885,15 @@ public function flushClearsPoisonQueueWhenPoisonEnabled(): void
872885 {
873886 $ queue = $ this ->createQueue ('test-queue ' , ['usePoisonQueue ' => true ]);
874887
875- $ this ->queueService ->expects ($ this ->exactly (2 ))
888+ $ matcher = $ this ->exactly (2 );
889+ $ this ->queueService ->expects ($ matcher )
876890 ->method ('clearMessages ' )
877- ->withConsecutive (
878- ['test-queue ' ],
879- ['test-queue-poison ' ]
880- );
891+ ->willReturnCallback (function (string $ queueName ) use ($ matcher ) {
892+ match ($ matcher ->numberOfInvocations ()) {
893+ 1 => $ this ->assertEquals ($ queueName , 'test-queue ' ),
894+ 2 => $ this ->assertEquals ($ queueName , 'test-queue-poison ' ),
895+ };
896+ });
881897
882898 $ listBlobsResult = $ this ->createMock (ListBlobsResult::class);
883899 $ listBlobsResult ->method ('getBlobs ' )->willReturn ([]);
0 commit comments