private void createSubscription()

in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java [480:501]

• 22 lines of code
• 4 McCabe index (conditional complexity)

  private void createSubscription() {
    logger.info("Creating subscription " + fullSubscriptionName);
    Subscription.Builder builder =
        Subscription.newBuilder()
            .setName(fullSubscriptionName.toString())
            .setTopic(fullTopicName.toString())
            .setAckDeadlineSeconds(ackDeadlineSeconds);
    if (messageFilteredProbability > 0.0) {
      builder.setFilter("attributes." + FILTERED_ATTRIBUTE + " != \"true\"");
    }
    builder = updateSubscriptionBuilder(builder);
    Subscription subscription = builder.build();
    try {
      subscriptionAdminClient.createSubscription(builder.build());
      logger.info("Created subscription " + fullSubscriptionName);
    } catch (Exception e) {
      if (e instanceof InterruptedException) {
        Thread.currentThread().interrupt();
      }
      logger.log(Level.WARNING, "Failed to create subscription " + fullSubscriptionName, e);
    }
  }