Consumer class abstract

Consumer instance (associated with a PulsarClient instance).

Inheritance

• Object
• Closable
• Consumer

Constructors

Consumer()

Properties

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

ackMessage(MessageId messageId, bool cumulative) → Future

Acknowledge to the broker that a given message with messageId has been successfully processed by the application and can be discarded by the broker. With cumulative acknowledgement, the consumer can only acknowledge the last message received. Note: cumulative acknowledgement can't be used with shared subscription type

close() → Future

Close this instance.

inherited

getFlow(int messagePermits) → Future

Grant permission to the broker to send messagePermits messages to this consumer (flow control). Subsequent call to this method allows next messagePermits messages in addition to any number previously specified.

listen(void onData(GenericInputMessage event), {Function onError, void onDone(), bool cancelOnError}) → StreamSubscription<GenericInputMessage>

Assign an input messages listener for the consumer.

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