apalis-amqp

Overview

apalis-amqp is a Rust crate that provides utilities for integrating apalis with AMQP message queuing systems. It includes an AmqpBackend implementation for use with the pushing and popping jobs, as well as a MessageQueue<J> implementation for consuming messages from an AMQP queue and passing them to ReadyWorker for processing.

Features

• Integration between apalis and AMQP message queuing systems.
• Easy creation of AMQP-backed job queues.
• Simple consumption of AMQP messages as apalis jobs.
• Supports message acknowledgement and rejection via tower layers.
• Supports all apalis middleware such as rate-limiting, timeouts, filtering, sentry, prometheus etc.

Getting started

Add apalis-amqp to your Cargo.toml file:

Setup RabbitMq

docker run -p 15672:15672 -p 5672:5672 -e RABBITMQ_DEFAULT_USER=apalis -e RABBITMQ_DEFAULT_PASS=apalis rabbitmq:3.8.4-management

Setup the rust code

toml [dependencies] apalis = "0.4.0-alpha.9" apalis-amqp = "v0.2.0-alpha.3" serde = "1"

Then add to your main.rs

````rust use apalis::prelude::*; use apalis_amqp::AmqpBackend; use serde::{Deserialize, Serialize};

[derive(Debug, Clone, Serialize, Deserialize)]

struct TestJob;

impl Job for TestJob { const NAME: &'static str = "TestJob"; }

async fn test_job(job: TestJob, ctx: JobContext) { dbg!(job); dbg!(ctx); }

[tokio::main]

async fn main() { let env = std::env::var("AMQPADDR").unwrap(); let mq = AmqpBackend::::newfromaddr(&env).await.unwrap(); mq.push(TestJob(42)).await.unwrap(); Monitor::new() .register( WorkerBuilder::new("rango-amigo") .withmq(mq) .buildfn(testjob), ) .run() .await .unwrap(); }

````

License

apalis-amqp is licensed under the Apache license. See the LICENSE file for details.