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

Class EventHubsChannelProvisioner

java.lang.Object

com.azure.spring.cloud.stream.binder.eventhubs.core.provisioning.EventHubsChannelProvisioner

All Implemented Interfaces:

org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>>

public class EventHubsChannelProvisioner
extends Object
implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>>

Constructor Summary

Constructors

Constructor	Description
EventHubsChannelProvisioner()

Method Summary

Modifier and Type	Method	Description
org.springframework.cloud.stream.provisioning.ConsumerDestination	provisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties> properties)
org.springframework.cloud.stream.provisioning.ProducerDestination	provisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties> properties)
protected void	validateOrCreateForConsumer(String name, String group)	Validate or create for consumer.
protected void	validateOrCreateForProducer(String name)	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

EventHubsChannelProvisioner

public EventHubsChannelProvisioner()

Method Details

provisionProducerDestination

public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String name,
 org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties> 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<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>>

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<EventHubsConsumerProperties> 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<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>>

Throws:

org.springframework.cloud.stream.provisioning.ProvisioningException

validateOrCreateForConsumer

protected void validateOrCreateForConsumer(String name,
 String group)

Validate or create for consumer.

Parameters:

name - the name

group - the group

validateOrCreateForProducer

protected void validateOrCreateForProducer(String name)

Validate or create for producer.

Parameters:

name - the name