PulsarClient class abstract

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.

Inheritance

• Object
• Closable
• PulsarClient

Constructors

PulsarClient({PulsarClientSettings? settings})

factory

Properties

clientErrorStream → Stream<Object>

Global error/exception (not associated with individual request completion) stream.

no setter

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

close() → Future

Close this instance.

inherited

newConsumer(ConsumerCreateParams params) → Future<Consumer>

Create new consumer instance with specified parameters.

newProducer(ProducerCreateParams params) → Future<Producer>

Create new producer instance with specified parameters.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited