camel-core 0.7.0

Core engine for rust-camel
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use camel_api::{BoxProcessor, BoxProcessorExt, Exchange};
use camel_component_timer::TimerComponent;
use camel_core::context::CamelContext;
use camel_core::route::{BuilderStep, RouteDefinition};
use criterion::{BenchmarkId, Criterion, criterion_group, criterion_main};

fn pass_through() -> BoxProcessor {
    BoxProcessor::from_fn(|ex: Exchange| Box::pin(async move { Ok(ex) }))
}

fn bench_lifecycle(c: &mut Criterion) {
    let mut group = c.benchmark_group("lifecycle/route_start_stop");
    let rt = tokio::runtime::Runtime::new().unwrap();

    for count in [1, 5, 20] {
        group.bench_with_input(
            BenchmarkId::new("add_start_stop", count),
            &count,
            |b, &count| {
                b.to_async(&rt).iter(|| async move {
                    let mut ctx = CamelContext::builder().build().await.unwrap();
                    ctx.register_component(TimerComponent::new());

                    for i in 0..count {
                        let route = RouteDefinition::new(
                            format!("timer:tick-{i}?period=1000"),
                            vec![BuilderStep::Processor(pass_through())],
                        )
                        .with_route_id(format!("bench-lifecycle-{i}"));
                        ctx.add_route_definition(route).await.unwrap();
                    }

                    ctx.start().await.unwrap();
                    ctx.stop().await.unwrap();
                })
            },
        );
    }

    group.finish();
}

criterion_group!(benches, bench_lifecycle);
criterion_main!(benches);