pulsar_iot_client library

Classes

Closable: Closable interface.
Consumer: Consumer instance (associated with a PulsarClient instance).
ConsumerCreateParams: Parameters for a new Consumer instance creation.
GenericInputMessage: Input (received) message.
GenericMessage: Individual message sent/received.
MessageId: Unique id of the message, according to the BookKeeper LedgerEntry https://bookkeeper.apache.org/docs/latest/api/javadoc/org/apache/bookkeeper/client/LedgerEntry.html. This id is assigned when appending (upon sending by the Producer) and can be used/stored as a reference in a future.
Producer: Producer instance (associated with a PulsarClient instance).
ProducerCreateParams: Parameters for a new Producer instance creation.
ProducerSendResult: Result of sending a message/batch by the Producer.
PulsarClient: The library client class. Although it's possible to have multiple instances of it running independently, it's recommended to use a single PulsarClient instance for a particular Pulsar cluster.
PulsarClientSettings: (Optional) settings for the PulsarClient instance.

MessageStorageType: Determines how the message was stored (i.e. delivered) on the broker side.
SubscriptionType: Subscription type. See https://pulsar.apache.org/docs/en/next/concepts-messaging/#subscription-types for details.