public void verifySubscription()

in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java [303:325]

23 lines of code
2 McCabe index (conditional complexity)


  public void verifySubscription(String cpsProject, String cpsSubscription, CredentialsProvider credentialsProvider) {
    try {
      SubscriberStubSettings subscriberStubSettings =
      SubscriberStubSettings.newBuilder()
        .setTransportChannelProvider(
            SubscriberStubSettings.defaultGrpcTransportProviderBuilder()
                .setMaxInboundMessageSize(20 << 20) // 20MB
                .build())
        .setCredentialsProvider(credentialsProvider)
        .build();
      GrpcSubscriberStub stub = GrpcSubscriberStub.create(subscriberStubSettings);
      GetSubscriptionRequest request =
          GetSubscriptionRequest.newBuilder()
              .setSubscription(
                  String.format(
                      ConnectorUtils.CPS_SUBSCRIPTION_FORMAT, cpsProject, cpsSubscription))
              .build();
      stub.getSubscriptionCallable().call(request);
    } catch (Exception e) {
      throw new ConnectException(
          "Error verifying the subscription " + cpsSubscription + " for project " + cpsProject, e);
    }
  }