com.google.cloud.spring.stream.binder.pubsub.provisioning

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 Summary

Constructors

Constructor and Description
PubSubChannelProvisioner(PubSubAdmin pubSubAdmin)

Method Summary

Modifier and Type	Method and Description
void	afterUnbindConsumer(org.springframework.cloud.stream.provisioning.ConsumerDestination destination)
org.springframework.cloud.stream.provisioning.ConsumerDestination	provisionConsumerDestination(String topicName, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties)
org.springframework.cloud.stream.provisioning.ProducerDestination	provisionProducerDestination(String topic, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties> properties)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PubSubChannelProvisioner

public PubSubChannelProvisioner(PubSubAdmin pubSubAdmin)

Method Detail

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)