stomp 0.5.1

A full STOMP 1.2 client implementation. Allows programs to interact with message queueing services like ActiveMQ and RabbitMQ.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use frame::Frame;
use std::old_io::IoResult;
use header::Header;
use session::Session;

pub struct Transaction<'a, 'b: 'a> {
  pub id: String, 
  pub session: &'a mut Session<'b>
}

impl <'a, 'b> Transaction<'a, 'b> {
  pub fn new(id: u32, session: &'a mut Session<'b>) -> Transaction<'a, 'b> {
    Transaction {
      id: format!("tx/{}",id),
      session: session,
    }
  }

  pub fn send_bytes(&mut self, topic: &str, mime_type: &str, body: &[u8]) -> IoResult<()> {
    let mut send_frame = Frame::send(topic, mime_type, body);
    send_frame.headers.push(
      Header::encode_key_value("transaction", self.id.as_slice())
    );
    self.session.send(send_frame)
  }

  pub fn send_text(&mut self, topic: &str, body: &str) -> IoResult<()> {
    self.send_bytes(topic, "text/plain", body.as_bytes())
  }

  pub fn begin(&mut self) -> IoResult<()> {
    let begin_frame = Frame::begin(self.id.as_slice());
    self.session.send(begin_frame)
  }

  pub fn commit(&mut self) -> IoResult<()> {
    let commit_frame = Frame::commit(self.id.as_slice());
    self.session.send(commit_frame)
  }

  pub fn abort(&mut self) -> IoResult<()> {
    let abort_frame = Frame::abort(self.id.as_slice());
    self.session.send(abort_frame)
  }
}