stomp 0.3.3

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
46
47
48
49

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

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

impl <'a> Transaction<'a> {
  pub fn new<'a>(id: uint, session: &'a mut Session) -> Transaction<'a> {
    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())
    );
    //Ok(try!(self.session.send(send_frame)))
    Ok(self.session.send(send_frame))
  }

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

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

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

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