CloudflareQueueDelivery class final

One message delivered to a Cloudflare Queue consumer Worker.

The acknowledgement methods map directly to Cloudflare's synchronous Message.ack() and Message.retry() operations. They are intentionally synchronous because Cloudflare records the decision before the queue handler returns.

Constructors

CloudflareQueueDelivery({required String id, required DateTime timestamp, required int attempts, required Object? body, required void acknowledge(), required void retryHandler(Duration? delay)})

Creates a queue delivery value.

Properties

attempts → int

One-based delivery attempt count.

final

body → Object?

Structured-clone body delivered by Cloudflare.

final

hashCode → int

The hash code for this object.

no setter, inherited

id → String

Unique Cloudflare message identifier.

final

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

timestamp → DateTime

Time at which Cloudflare accepted the message.

final

Methods

ack() → void

Acknowledges this message as successfully handled.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

retry({Duration? delay}) → void

Requests a later delivery of this message.

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited