anchor.diff:  
   Please refer to our https://github.com/GoogleCloudPlatform/spring-cloud-gcp/tree/main/spring-cloud-gcp-samples/spring-cloud-gcp-integration-pubsub-json-sample[Pub/Sub JSON Payload Sample App] as a reference for using this functionality.
   
  -=== Reactive Stream Subscription
  +=== Reactive Stream Subscriber
   
   It is also possible to acquire a reactive stream backed by a subscription.
   To do so, a Project Reactor dependency (`io.projectreactor:reactor-core`) must be added to the project.
  
positive.code: 
  ==== Creating a subscription
  
  `PubSubAdmin` implements a method to create subscriptions to existing topics:
  
  [source,java]
  ----
  public Subscription createSubscription(String subscriptionName, String topicName, Integer ackDeadline, String pushEndpoint)
  ----
  
  Here is an example of how to create a Google Cloud Pub/Sub subscription:
  
  [source,java]
  ----
  public void newSubscription() {
      pubSubAdmin.createSubscription("subscriptionName", "topicName", 10, “https://my.endpoint/push”);
  }
  ----
  
  Alternative methods with default settings are provided for ease of use.
  The default value for `ackDeadline` is 10 seconds.
  If `pushEndpoint` isn’t specified, the subscription uses message pulling, instead.
  
  [source,java]
  ----
  public Subscription createSubscription(String subscriptionName, String topicName)
  ----
  
  [source,java]
  ----
  public Subscription createSubscription(String subscriptionName, String topicName, Integer ackDeadline)
  ----
  
  [source,java]
  ----
  public Subscription createSubscription(String subscriptionName, String topicName, String pushEndpoint)
  ----
  
  You can also pass a full `Subscription.Builder` for full access to any options or features available in the client library.
  
  [source,java]
  ----
  public Subscription createSubscription(Subscription.Builder builder)
  ----
  
  ==== Deleting a subscription
  
negative.code: 
  NOTE: Generally when referring to topics and subscriptions, you can either use the short canonical name within the current project, or the fully-qualified name referring to a topic or subscription in a different project using the `projects/<project_name>/(topics|subscriptions)/<name>` format.
  
  The Spring Boot starter for GCP Pub/Sub auto-configures a `PubSubAdmin` object using the `GcpProjectIdProvider` and the `CredentialsProvider` auto-configured by the Spring Boot GCP Core starter.
  
  ==== Creating a topic
  