class Crabbit::Delivery

• Crabbit::Delivery
• Reference
• Object

Overview

One logical message delivered from a RabbitMQ stream.

The raw AMQP payload is available immediately. #message decodes it lazily and caches the result. Pull consumers must call #processed! after successful processing so Crabbit can replenish chunk credit and advance the recovery offset.

Defined in:

crabbit/consumer.cr

Instance Method Summary

• #body : Bytes

  Returns the logical Data body from #message.

• #committed_chunk_id : UInt64

  Returns the committed chunk ID reported by RabbitMQ.

• #message : Message

  Lazily decodes and returns the complete AMQP message.

• #offset : UInt64

  Returns the absolute stream offset.

• #processed! : Nil

  Idempotently marks this delivery as processed.

• #processed? : Bool

  Returns whether processing was acknowledged locally.

• #raw : Bytes

  Returns the complete encoded AMQP message bytes.

• #stream : String

  Returns the source stream name.

• #timestamp : Time

  Returns the broker chunk timestamp.

Instance Method Detail