+ private boolean checkSupportedStream(
+ String streamName,
+ ListenableFuture<RpcResult<CreateSubscriptionOutput>> subscription) {
+ boolean subscriptionSuccessful = false;
+ try {
+ // Using if condition does not work, since we need to handle exceptions
+ subscriptionSuccessful = subscription.get().isSuccessful();
+ LOG.info("{} subscription is {}", streamName, subscriptionSuccessful);
+ } catch (InterruptedException | ExecutionException e) {
+ LOG.error("Error during subscription to stream {}", streamName, e);
+ }
+ return subscriptionSuccessful;
+ }
+
+ private List<String> getSupportedStream(String nodeId) {