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 Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    CompletableFuture<Void>
    closeAsync()
     
    CompletableFuture<List<String>>
    getPartitionsForTopic(String topic, boolean metadataAutoCreationEnabled)
     
    boolean
    isClosed()
     
    org.apache.pulsar.client.api.ConsumerBuilder<byte[]>
    newConsumer()
     
    <T> org.apache.pulsar.client.api.ConsumerBuilder<T>
    newConsumer(org.apache.pulsar.client.api.Schema<T> schema)
     
    org.apache.pulsar.client.api.ProducerBuilder<byte[]>
    newProducer()
     
    <T> org.apache.pulsar.client.api.ProducerBuilder<T>
    newProducer(org.apache.pulsar.client.api.Schema<T> schema)
     
    org.apache.pulsar.client.api.ReaderBuilder<byte[]>
    newReader()
     
    <T> org.apache.pulsar.client.api.ReaderBuilder<T>
    newReader(org.apache.pulsar.client.api.Schema<T> schema)
     
    org.apache.pulsar.client.api.TableViewBuilder<byte[]>
    newTableView()
     
    <T> org.apache.pulsar.client.api.TableViewBuilder<T>
    newTableView(org.apache.pulsar.client.api.Schema<T> schema)
     
    <T> org.apache.pulsar.client.api.TableViewBuilder<T>
    newTableViewBuilder(org.apache.pulsar.client.api.Schema<T> schema)
     
    org.apache.pulsar.client.api.transaction.TransactionBuilder
    newTransaction()
     
    void
    shutdown()
     
    org.apache.pulsar.client.api.PulsarClient
    unwrap()
     
    static org.apache.pulsar.client.api.PulsarClient
    unwrap(org.apache.pulsar.client.api.PulsarClient delegate)
     
    void
    updateServiceUrl(String serviceUrl)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.pulsar.client.api.PulsarClient

    getPartitionsForTopic

  • 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