@@ -3255,7 +3255,7 @@ public void testRollForwardPartialFailure() {
3255
3255
verify (adminSpy , times (5 )).getCurrentVersionsForMultiColos (clusterName , storeName );
3256
3256
}
3257
3257
3258
- @ Test ( expectedExceptions = AdminMessageConsumptionTimeoutException . class )
3258
+ @ Test
3259
3259
public void testDeleteStoreAdminMessageTimeout () {
3260
3260
VeniceParentHelixAdmin adminSpy = spy (parentAdmin );
3261
3261
@@ -3265,11 +3265,16 @@ public void testDeleteStoreAdminMessageTimeout() {
3265
3265
doReturn (store ).when (internalAdmin ).getStore (eq (clusterName ), eq (storeName ));
3266
3266
doReturn (store ).when (internalAdmin ).checkPreConditionForDeletion (eq (clusterName ), eq (storeName ));
3267
3267
3268
- AdminMessageConsumptionTimeoutException exception =
3268
+ AdminMessageConsumptionTimeoutException expectedException =
3269
3269
new AdminMessageConsumptionTimeoutException ("timed out!" , new Exception ());
3270
- doThrow (exception ).when (adminSpy ).sendAdminMessageAndWaitForConsumed (any (), any (), any ());
3271
- adminSpy .deleteStore (clusterName , storeName , false , 0 , true );
3272
- verify (adminSpy , times (1 )).deleteAclsForStore (store , storeName );
3270
+ doThrow (expectedException ).when (adminSpy ).sendAdminMessageAndWaitForConsumed (any (), any (), any ());
3271
+ try {
3272
+ adminSpy .deleteStore (clusterName , storeName , false , 0 , true );
3273
+ Assert .fail ("Delete store should time out" );
3274
+ } catch (AdminMessageConsumptionTimeoutException e ) {
3275
+ Assert .assertEquals (e , expectedException );
3276
+ verify (adminSpy , times (1 )).deleteAclsForStore (store , storeName );
3277
+ }
3273
3278
}
3274
3279
3275
3280
private Store setupForStoreViewConfigUpdateTest (String storeName ) {
0 commit comments