Class PulsarTopicProvisioner
java.lang.Object
org.springframework.pulsar.spring.cloud.stream.binder.provisioning.PulsarTopicProvisioner
- All Implemented Interfaces:
org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>>
public class PulsarTopicProvisioner
extends Object
implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>>
Pulsar topic provisioner.
- Author:
- Soby Chacko
-
Constructor Summary
ConstructorsConstructorDescriptionPulsarTopicProvisioner(PulsarAdministration pulsarAdministration, PulsarBinderConfigurationProperties pulsarBinderConfigurationProperties) -
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.cloud.stream.provisioning.ConsumerDestinationprovisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties> pulsarConsumerProperties) org.springframework.cloud.stream.provisioning.ProducerDestinationprovisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties> pulsarProducerProperties)
-
Constructor Details
-
PulsarTopicProvisioner
public PulsarTopicProvisioner(PulsarAdministration pulsarAdministration, PulsarBinderConfigurationProperties pulsarBinderConfigurationProperties)
-
-
Method Details
-
provisionProducerDestination
public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties> pulsarProducerProperties) throws org.springframework.cloud.stream.provisioning.ProvisioningException - Specified by:
provisionProducerDestinationin interfaceorg.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>> - 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<PulsarConsumerProperties> pulsarConsumerProperties) throws org.springframework.cloud.stream.provisioning.ProvisioningException - Specified by:
provisionConsumerDestinationin interfaceorg.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>> - Throws:
org.springframework.cloud.stream.provisioning.ProvisioningException
-