class

Crabbit::ConsumerUpdateContext

Inherits Reference < Object

Context passed to the context-aware Single Active Consumer update callback.

The callback returns the OffsetSpecification to use for the new active or inactive state. #consumer can query a stored offset when making that decision.

Instance methods

active

Returns whether this subscription is becoming active.

Source
consumer

Returns the affected consumer.

Source
stream

Returns the partition stream receiving the update.

Source