sidekiq

Function with_custom_namespace

Source 
pub fn with_custom_namespace(namespace: String) -> Box<NamespaceCustomizer>
Examples found in repository?
examples/namespaced_demo.rs (line 25)
18async fn main() -> Result<()> {
19    tracing_subscriber::fmt::init();
20
21    // Redis
22    let manager = RedisConnectionManager::new("redis://127.0.0.1/")?;
23    let redis = Pool::builder()
24        .max_size(100)
25        .connection_customizer(sidekiq::with_custom_namespace("yolo_app".to_string()))
26        .build(manager)
27        .await?;
28
29    tokio::spawn({
30        let redis = redis.clone();
31
32        async move {
33            loop {
34                HelloWorker::perform_async(&redis, ()).await.unwrap();
35
36                tokio::time::sleep(std::time::Duration::from_secs(1)).await;
37            }
38        }
39    });
40
41    // Sidekiq server
42    let mut p = Processor::new(redis.clone(), vec!["default".to_string()]);
43
44    // Add known workers
45    p.register(HelloWorker);
46
47    // Start!
48    p.run().await;
49    Ok(())
50}