@@ -810,7 +810,6 @@ public async Task TestShardedPubsubSubscriberAgainsHashSlotMigration()
810810 using var conn = Create ( allowAdmin : true , keepAlive : 1 , connectTimeout : 3000 , shared : false ) ;
811811 Assert . True ( conn . IsConnected ) ;
812812 var db = conn . GetDatabase ( ) ;
813- db . StringSet ( "testShardChannel" , "testValue" ) ;
814813 Assert . Equal ( 0 , await db . PublishAsync ( channel , "noClientReceivesThis" ) ) ;
815814 await Task . Delay ( 50 ) ; // let the sub settle (this isn't needed on RESP3, note)
816815
@@ -891,27 +890,23 @@ private void MigrateSlotForTestShardChannel(bool rollback)
891890
892891 IServer fromServer , toServer ;
893892 string fromNode , toNode ;
894- int toPort ;
895893 if ( rollback )
896894 {
897895 fromServer = serverWithPort7000 ! ;
898896 fromNode = nodeIdForPort7000 ;
899897 toServer = serverWithPort7001 ! ;
900898 toNode = nodeIdForPort7001 ;
901- toPort = 7001 ;
902899 }
903900 else
904901 {
905902 fromServer = serverWithPort7001 ! ;
906903 fromNode = nodeIdForPort7001 ;
907904 toServer = serverWithPort7000 ! ;
908905 toNode = nodeIdForPort7000 ;
909- toPort = 7000 ;
910906 }
911907
912908 Assert . Equal ( "OK" , toServer . Execute ( "CLUSTER" , "SETSLOT" , hashSlotForTestShardChannel , "IMPORTING" , fromNode ) . ToString ( ) ) ;
913909 Assert . Equal ( "OK" , fromServer . Execute ( "CLUSTER" , "SETSLOT" , hashSlotForTestShardChannel , "MIGRATING" , toNode ) . ToString ( ) ) ;
914- Assert . Equal ( "OK" , fromServer . Execute ( "MIGRATE" , "127.0.0.1" , toPort , "" , 0 , 5000 , "KEYS" , "testShardChannel" ) . ToString ( ) ) ;
915910 Assert . Equal ( "OK" , toServer . Execute ( "CLUSTER" , "SETSLOT" , hashSlotForTestShardChannel , "NODE" , toNode ) . ToString ( ) ) ;
916911 Assert . Equal ( "OK" , fromServer ! . Execute ( "CLUSTER" , "SETSLOT" , hashSlotForTestShardChannel , "NODE" , toNode ) . ToString ( ) ) ;
917912 }
0 commit comments