Package com.hazelcast.jet.pulsar

Class CloseablePulsarClient

java.lang.Object
com.hazelcast.jet.pulsar.CloseablePulsarClient
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.pulsar.client.api.PulsarClient
public final class CloseablePulsarClient extends Object implements org.apache.pulsar.client.api.PulsarClient

  • Method Details

    • unwrap

      public static org.apache.pulsar.client.api.PulsarClient unwrap(org.apache.pulsar.client.api.PulsarClient delegate)

    • unwrap

      public org.apache.pulsar.client.api.PulsarClient unwrap()

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.pulsar.client.api.PulsarClient

    • isClosed

      public boolean isClosed()
      Specified by:
      isClosed in interface org.apache.pulsar.client.api.PulsarClient

    • newProducer

      public org.apache.pulsar.client.api.ProducerBuilder<byte[]> newProducer()
      Specified by:
      newProducer in interface org.apache.pulsar.client.api.PulsarClient

    • newProducer

      public <T> org.apache.pulsar.client.api.ProducerBuilder<T> newProducer(org.apache.pulsar.client.api.Schema<T> schema)
      Specified by:
      newProducer in interface org.apache.pulsar.client.api.PulsarClient

    • newConsumer

      public org.apache.pulsar.client.api.ConsumerBuilder<byte[]> newConsumer()
      Specified by:
      newConsumer in interface org.apache.pulsar.client.api.PulsarClient

    • newConsumer

      public <T> org.apache.pulsar.client.api.ConsumerBuilder<T> newConsumer(org.apache.pulsar.client.api.Schema<T> schema)
      Specified by:
      newConsumer in interface org.apache.pulsar.client.api.PulsarClient

    • newReader

      public org.apache.pulsar.client.api.ReaderBuilder<byte[]> newReader()
      Specified by:
      newReader in interface org.apache.pulsar.client.api.PulsarClient

    • newReader

      public <T> org.apache.pulsar.client.api.ReaderBuilder<T> newReader(org.apache.pulsar.client.api.Schema<T> schema)
      Specified by:
      newReader in interface org.apache.pulsar.client.api.PulsarClient

    • newTableViewBuilder

      public <T> org.apache.pulsar.client.api.TableViewBuilder<T> newTableViewBuilder(org.apache.pulsar.client.api.Schema<T> schema)
      Specified by:
      newTableViewBuilder in interface org.apache.pulsar.client.api.PulsarClient

    • newTableView

      public org.apache.pulsar.client.api.TableViewBuilder<byte[]> newTableView()
      Specified by:
      newTableView in interface org.apache.pulsar.client.api.PulsarClient

    • newTableView

      public <T> org.apache.pulsar.client.api.TableViewBuilder<T> newTableView(org.apache.pulsar.client.api.Schema<T> schema)
      Specified by:
      newTableView in interface org.apache.pulsar.client.api.PulsarClient

    • updateServiceUrl

      public void updateServiceUrl(String serviceUrl) throws org.apache.pulsar.client.api.PulsarClientException
      Specified by:
      updateServiceUrl in interface org.apache.pulsar.client.api.PulsarClient
      Throws:
      org.apache.pulsar.client.api.PulsarClientException

    • getPartitionsForTopic

      public CompletableFuture<List<String>> getPartitionsForTopic(String topic, boolean metadataAutoCreationEnabled)
      Specified by:
      getPartitionsForTopic in interface org.apache.pulsar.client.api.PulsarClient

    • closeAsync

      public CompletableFuture<Void> closeAsync()
      Specified by:
      closeAsync in interface org.apache.pulsar.client.api.PulsarClient

    • shutdown

      public void shutdown()
      Specified by:
      shutdown in interface org.apache.pulsar.client.api.PulsarClient

    • newTransaction

      public org.apache.pulsar.client.api.transaction.TransactionBuilder newTransaction()
      Specified by:
      newTransaction in interface org.apache.pulsar.client.api.PulsarClient

    • getTransactionCoordinatorClient

      public org.apache.pulsar.client.api.transaction.TransactionCoordinatorClient getTransactionCoordinatorClient()
      Specified by:
      getTransactionCoordinatorClient in interface org.apache.pulsar.client.api.PulsarClient