tokio-stomp-2

Crates.iotokio-stomp-2
lib.rstokio-stomp-2
version0.3.0
sourcesrc
created_at2021-04-07 14:54:38.28553
updated_at2023-06-28 13:19:40.36463
descriptionUnofficial successor to Asynchronous streaming STOMP client
homepagehttp://github.com/alexkunde/tokio-stomp-2
repositoryhttp://github.com/alexkunde/tokio-stomp-2
max_upload_size
id380380
size52,961
Jens Walter (JensWalter)

documentation

README

Convinience Release

  • Use with care
  • If you don't know what you are doing, use the original tokio-stomp
  • Added sending and receiving headers

tokio-stomp-2

crates.io

An async STOMP client (and maybe eventually, server) for Rust, using the Tokio stack.

It aims to be fast and fully-featured with a simple streaming interface.

Examples

Sending a message to a queue.

use futures::prelude::*;
use tokio_stomp_2::client;
use tokio_stomp_2::ToServer;

#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
  let mut conn = client::connect("127.0.0.1:61613", None, None).await.unwrap();
  
  conn.send(
    ToServer::Send {
        destination: "queue.test".into(),
        transaction: None,
        headers: vec!(),
        body: Some(b"Hello there rustaceans!".to_vec()),
    }
    .into(),
  )
  .await.expect("sending message to server");
  Ok(())
}

Receiving a message from a queue.

use futures::prelude::*;
use tokio_stomp_2::client;
use tokio_stomp_2::FromServer;

#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
  let mut conn = client::connect("127.0.0.1:61613", None, None).await.unwrap();
  conn.send(client::subscribe("queue.test", "custom-subscriber-id")).await.unwrap();

  while let Some(item) = conn.next().await {
    if let FromServer::Message { message_id,body, .. } = item.unwrap().content {
      println!("{:?}", body);
      println!("{}", message_id);
    }
  }
  Ok(())
}

For full examples, see the examples directory.

License: MIT

Commit count: 0

cargo fmt