class Crabbit::ConsumerUpdateContext

• Crabbit::ConsumerUpdateContext
• Reference
• Object

Overview

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.

Defined in:

crabbit/consumer.cr

Instance Method Summary

• #active : Bool

  Returns whether this subscription is becoming active.

• #consumer : Consumer

  Returns the affected consumer.

• #stream : String

  Returns the partition stream receiving the update.

Instance Method Detail