Struct MessageBuilder 

pub struct MessageBuilder { /* private fields */ }

Fluent builder for creating Celery messages

Implementations

impl MessageBuilder

pub fn new(task: impl Into<String>) -> Self

Create a new message builder with the given task name

pub fn id(self, id: Uuid) -> Self

Set the task ID

pub fn args(self, args: Vec<Value>) -> Self

Set positional arguments

pub fn arg(self, arg: Value) -> Self

Add a positional argument

pub fn kwargs(self, kwargs: HashMap<String, Value>) -> Self

Set keyword arguments

pub fn kwarg(self, key: impl Into<String>, value: Value) -> Self

Add a keyword argument

pub fn priority(self, priority: u8) -> Self

Set task priority (0-9, higher = more urgent)

pub fn queue(self, queue: impl Into<String>) -> Self

Set the queue name

pub fn routing_key(self, key: impl Into<String>) -> Self

Set the routing key

pub fn eta(self, eta: DateTime<Utc>) -> Self

Set ETA (scheduled execution time)

pub fn countdown(self, seconds: i64) -> Self

Set countdown (delay in seconds)

pub fn expires(self, expires: DateTime<Utc>) -> Self

Set expiration time

pub fn expires_in(self, duration: Duration) -> Self

Set expiration as duration from now

pub fn max_retries(self, max: u32) -> Self

Set maximum retries

pub fn retries(self, count: u32) -> Self

Set current retry count

pub fn parent(self, parent_id: Uuid) -> Self

Set parent task ID

pub fn root(self, root_id: Uuid) -> Self

Set root task ID

pub fn group(self, group_id: Uuid) -> Self

Set group ID

pub fn link(self, task: impl Into<String>) -> Self

Add a success callback (link)

pub fn link_signature(self, callback: CallbackSignature) -> Self

Add a success callback with full signature

pub fn link_error(self, task: impl Into<String>) -> Self

Add an error callback (errback)

pub fn link_error_signature(self, errback: CallbackSignature) -> Self

Add an error callback with full signature

pub fn chain_task(self, task: impl Into<String>) -> Self

Add a chain task

pub fn chord(self, callback: impl Into<String>) -> Self

Set chord callback

pub fn content_type(self, ct: ContentType) -> Self

Set content type

pub fn persistent(self, persistent: bool) -> Self

Set message persistence

pub fn reply_to(self, queue: impl Into<String>) -> Self

Set reply-to queue

pub fn header(self, key: impl Into<String>, value: Value) -> Self

Add extra header

pub fn build(self) -> BuilderResult<Message>

Build the message

pub fn build_validated(self) -> BuilderResult<Message>

Build and validate the message

Trait Implementations

impl Clone for MessageBuilder

fn clone(&self) -> MessageBuilder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessageBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.