stomp-rs

stomp-rs provides a full STOMP 1.2 client implementation for the Rust programming language. This allows programs written in Rust to interact with message queueing services like ActiveMQ and RabbitMQ.

• [x] Connect
• [x] Subscribe
• [x] Send
• [x] Acknowledge (Auto/Client/ClientIndividual)
• [x] Transactions
• [x] Receipts
• [x] Disconnect
• [x] Heartbeats

The APIs for stomp-rs are not yet stable and are likely to fluctuate before v1.0.

Examples

Connect / Subscribe / Send

```rust extern crate stomp; use stomp::frame::Frame; use stomp::subscription::AckOrNack; use stomp::subscription::AckOrNack::Ack; use stomp::subscription::AckMode::Auto;

fn main() { let mut session = match stomp::connect("127.0.0.1", 61613) { Ok(session) => session, Err(error) => panic!("Could not connect to the server: {}", error) };

// The callback system will switch to unboxed closures when that language feature is available fn on_message(frame: &Frame) -> AckOrNack { println!("Received a message:\n{}", frame); Ack }

let topic = "/topic/messages"; session.subscribe(topic, Client, on_message); // 'client' acknowledgement mode

// Send arbitrary bytes with a specified MIME type session.sendbytes(topic, "text/plain", "Animal".asbytes());

// Send UTF-8 text with an assumed MIME type of 'text/plain' session.sendtext(topic, "Vegetable"); session.sendtext(topic, "Mineral");

session.listen(); // Loops infinitely, awaiting messages } ```

Transactions

```rust let mut tx = match session.begin_transaction() { Ok(tx) => tx, Err(error) => panic!("Could not begin new transaction: {}", error) };

tx.sendtext(topic, "Animal"); tx.sendtext(topic, "Vegetable"); tx.send_text(topic, "Mineral");

tx.commit(); // Or tx.abort(); ```

Receipts

rust session.send_text_with_receipt(topic, "Modern Major General"); debug!("Oustanding Receipt IDs: {}", session.oustanding_receipts());

Handling RECEIPT frames

```rust fn on_receipt(frame: &Frame) { debug!("RECEIPT frame received:\n{}", frame); }

session.onreceipt(onreceipt); session.sendtextwith_receipt(topic, "Modern Major General"); ```

Handling ERROR frames

```rust fn on_error(frame: &Frame) { panic!("ERROR frame received:\n{}", frame); }

session.onerror(onerror); ```

Cargo.toml

```toml [package]

name = "stomptest" version = "0.0.1" authors = ["yourname_here"]

[[bin]]

name = "stomp_test"

[dependencies.stomp]

git = "https://github.com/zslayton/stomp-rs.git" ```

keywords: Stomp, Rust, rust-lang, rustlang, cargo, ActiveMQ, RabbitMQ, Message Queue, MQ