Crate stomp_rs[−][src]

Expand description

Stomp lib

Creating a client:

use stomp_rs::Client;
use tokio::net::TcpStream;

let client = Client::new(
    TcpStream::connect("127.0.0.1:61613").await?,
    sender,
).await?;

Emitting a new frame:

use stomp_rs::protocol::frame::Send;

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