class

Crabbit::Delivery

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.

Instance methods

body

Returns the logical Data body from #message.

Source

committed_chunk_id

Returns the committed chunk ID reported by RabbitMQ.

Source

message

Lazily decodes and returns the complete AMQP message.

Source

offset

Returns the absolute stream offset.

Source

processed!

Idempotently marks this delivery as processed.

Credit is replenished only after every logical delivery in the same broker chunk is processed.

Source

processed?

Returns whether processing was acknowledged locally.

Source

raw

Returns the complete encoded AMQP message bytes.

This buffer owns the storage referenced by zero-copy #message values.

Source

stream

Returns the source stream name.

Source

timestamp

Returns the broker chunk timestamp.

Source