stomp-rs

Client

Creating new connection:

let client = Client::connect(
    ClientBuilder::new("127.0.0.1:61613".to_owned())
).await?;

Subscribing:

let (tx, mut rx) = channel();

client.subscribe("/topic/test".to_string(), None, tx)
    .await?;

if let Some(frame) = rx.recv().await {
    println!("Frame received: {}", frame.body);
}

Sending:

client.send(
    "/topic/test".to_string(),
    "test-message".to_string(),
    None,
).await?

Transaction:

let transaction = client.begin().await?;

transaction.send(
    "/topic/test".to_string(),
    "test-message".to_string(),
    None,
).await?