8 releases
0.2.2 | May 25, 2023 |
---|---|
0.2.1 | May 25, 2023 |
0.2.0-alpha.2 | Apr 12, 2023 |
0.1.1 | Apr 9, 2023 |
#766 in Database interfaces
50 downloads per month
22KB
174 lines
apalis-amqp
Message queuing for Rust using apalis and 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
[dependencies]
apalis = "0.4"
apalis-amqp = "0.2"
serde = "1"
Then add to your main.rs
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("AMQP_ADDR").unwrap();
let mq = AmqpBackend::<TestJob>::new_from_addr(&env).await.unwrap();
mq.push(TestJob(42)).await.unwrap();
Monitor::new()
.register(
WorkerBuilder::new("rango-amigo")
.with_mq(mq)
.build_fn(test_job),
)
.run()
.await
.unwrap();
}
License
apalis-amqp is licensed under the Apache license. See the LICENSE file for details.
Dependencies
~12–52MB
~824K SLoC