Macro app 

macro_rules! app {
    (
        broker = $broker_type:ty { $broker_url:expr },
        tasks = [ $( $t:ty ),* $(,)? ],
        task_routes = [ $( $pattern:expr => $queue:expr ),* $(,)? ]
        $(, $x:ident = $y:expr )* $(,)?
    ) => { ... };
}

A macro for creating a Celery app.

At a minimum the app! macro requires these 3 arguments (in order):

• broker: a broker type (currently only AMQP is supported) with an expression for the broker URL in brackets,
• tasks: a list of tasks to register, and
• task_routes: a list of routing rules in the form of pattern => queue.

Optional parameters

Following the task routing rules there are a number of other optional parameters that may appear in arbitrary order (all of which correspond to a method on the CeleryBuilder struct):

• default_queue: Set the CeleryBuilder::default_queue.
• prefetch_count: Set the CeleryBuilder::prefect_count.
• heartbeat: Set the CeleryBuilder::heartbeat.
• task_time_limit: Set an app-level TaskOptions::time_limit.
• task_hard_time_limit: Set an app-level TaskOptions::hard_time_limit.
• task_max_retries: Set an app-level TaskOptions::max_retries.
• task_min_retry_delay: Set an app-level TaskOptions::min_retry_delay.
• task_max_retry_delay: Set an app-level TaskOptions::max_retry_delay.
• task_retry_for_unexpected: Set an app-level TaskOptions::retry_for_unexpected.
• acks_late: Set an app-level TaskOptions::acks_late.
• broker_connection_timeout: Set the CeleryBuilder::broker_connection_timeout.
• broker_connection_retry: Set the CeleryBuilder::broker_connection_retry.
• broker_connection_max_retries: Set the CeleryBuilder::broker_connection_max_retries.

Examples

use celery::prelude::*;

#[celery::task]
fn add(x: i32, y: i32) -> TaskResult<i32> {
    Ok(x + y)
}

let app = celery::app!(
    broker = AMQPBroker { std::env::var("AMQP_ADDR").unwrap() },
    tasks = [ add ],
    task_routes = [ "*" => "celery" ],
).await?;

let app = celery::app!(
    broker = AMQPBroker { std::env::var("AMQP_ADDR").unwrap() },
    tasks = [],
    task_routes = [],
    task_time_limit = 2
).await?;