Class PubSubChannelProvisioner

java.lang.Object
com.google.cloud.spring.stream.binder.pubsub.provisioning.PubSubChannelProvisioner
All Implemented Interfaces:
org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>>

public class PubSubChannelProvisioner extends Object implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>>
Provisioning provider for Pub/Sub.
  • Constructor Details

    • PubSubChannelProvisioner

      public PubSubChannelProvisioner(PubSubAdmin pubSubAdmin)
  • Method Details

    • provisionProducerDestination

      public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String topic, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties> properties)
      Specified by:
      provisionProducerDestination in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>>
    • provisionConsumerDestination

      public org.springframework.cloud.stream.provisioning.ConsumerDestination provisionConsumerDestination(String topicName, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties)
      Specified by:
      provisionConsumerDestination in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>>
    • afterUnbindConsumer

      public void afterUnbindConsumer(org.springframework.cloud.stream.provisioning.ConsumerDestination destination)