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 Details

  • 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:
      provisionProducerDestination in interface org.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:
      provisionConsumerDestination in interface org.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