luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Bug fix from last revision

Browse source
This commit is contained in:
Meher Mankikar 2023-06-19 16:25:01 -07:00
parent 97d7831446
commit ad26ac5149
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/StreamExistenceManager.java
View file

@ -43,10 +43,12 @@ public class StreamExistenceManager {
throw new RuntimeException("Stream is not active, instead in status: " + response.streamDescriptionSummary().streamStatus());
}
return true;
} catch (ResourceNotFoundException e) {
return false;
} catch (ExecutionException e) {
throw new RuntimeException(e);
if (e.getCause() instanceof ResourceNotFoundException) {
return false;
} else {
throw new RuntimeException(e);
}
} catch (Exception e) {
throw new RuntimeException(e);
}