oa_gateway_testing::stomp

Function start_stomp_adapter_with

Source
pub async fn start_stomp_adapter_with(
    engine: Arc<Engine>,
    id: impl Into<String>,
    broker: SocketAddr,
    topics: Vec<String>,
    settle: Duration,
    edit: impl FnOnce(&mut StompConfig),
) -> CancellationToken
Expand description

As start_stomp_adapter, with the config open for editing first — for example to set StompConfig::tls.