Crate apalis_nats

Source

Expand description

§apalis-nats

Background task processing in rust using apalis and nats-jetstream

§Features

Reliable message queue using nats-jetstream as the backend.
Multiple Polling strategies: pull and push polling.
Custom codecs for serializing/deserializing job arguments as bytes.
Integration with apalis workers and middleware.
Observability: Monitor and manage tasks using apalis-board.

§Examples

§Setting up

The fastest way to get started is by running the Docker image:

docker run -p 4222:4222 nats -js

§Basic Worker Example

use apalis::prelude::*;
use apalis_nats::*;
use futures::{self, SinkExt};
use std::env;
use std::collections::HashMap;

#[tokio::main]
async fn main() {
    let nats_url = env::var("NATS_URL")
        .unwrap_or_else(|_| "nats://localhost:4222".to_string());

    let client = async_nats::connect(nats_url).await.unwrap();

    let config = Config::new("events").with_pull_consumer();
    let mut backend = NatsJetStream::new(client, config).await;

    backend.send(Task::new(HashMap::new())).await.unwrap();

    async fn send_reminder(
        _: HashMap<String, String>,
        wrk: WorkerContext,
    ) -> Result<(), BoxDynError> {
        wrk.stop().unwrap();
        Ok(())
    }

    let worker = WorkerBuilder::new("rango-tango-1")
        .backend(backend)
        .build(send_reminder);
    worker.run().await.unwrap();
}