Package com.azure.spring.cloud.stream.binder.servicebus.core.provisioning

Class ServiceBusChannelProvisioner

java.lang.Object

com.azure.spring.cloud.stream.binder.servicebus.core.provisioning.ServiceBusChannelProvisioner

All Implemented Interfaces:

org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>>

public class ServiceBusChannelProvisioner
extends Object
implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>>

Constructor Summary

Constructors

Constructor	Description
ServiceBusChannelProvisioner()

Method Summary

Modifier and Type	Method	Description
org.springframework.cloud.stream.provisioning.ConsumerDestination	provisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties> properties)
org.springframework.cloud.stream.provisioning.ProducerDestination	provisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties> properties)
protected void	validateOrCreateForConsumer(String name, String group, com.azure.spring.cloud.service.servicebus.properties.ServiceBusEntityType type)	Validate or create for consumer.
protected void	validateOrCreateForProducer(String name, com.azure.spring.cloud.service.servicebus.properties.ServiceBusEntityType type)	Validate or create for producer.

Methods inherited from class java.lang.Object

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

Constructor Details

ServiceBusChannelProvisioner

public ServiceBusChannelProvisioner()

Method Details

provisionProducerDestination

public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String name,
 org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties> properties)
                                                                                               throws org.springframework.cloud.stream.provisioning.ProvisioningException

Specified by:

provisionProducerDestination in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>>

Throws:

org.springframework.cloud.stream.provisioning.ProvisioningException

provisionConsumerDestination

public org.springframework.cloud.stream.provisioning.ConsumerDestination provisionConsumerDestination(String name,
 String group,
 org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties> properties)
                                                                                               throws org.springframework.cloud.stream.provisioning.ProvisioningException

Specified by:

provisionConsumerDestination in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>>

Throws:

org.springframework.cloud.stream.provisioning.ProvisioningException

validateOrCreateForConsumer

protected void validateOrCreateForConsumer(String name,
 String group,
 com.azure.spring.cloud.service.servicebus.properties.ServiceBusEntityType type)

Validate or create for consumer.

Parameters:

name - the name

group - the group

type - the type

validateOrCreateForProducer

protected void validateOrCreateForProducer(String name,
 com.azure.spring.cloud.service.servicebus.properties.ServiceBusEntityType type)

Validate or create for producer.

Parameters:

name - the name

type - the type