stomp 0.8.2

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

use frame::Frame;
use frame::ToFrameBody;
use message_builder::MessageBuilder;
use std::io::Result;
use header::Header;
use session::Session;

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

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

  pub fn message<'b, T: ToFrameBody> (&'b mut self, destination: & str, body_convertible: T) -> MessageBuilder<'b, 'session> {
    let mut send_frame = Frame::send(destination, body_convertible.to_frame_body());
    send_frame.headers.push(Header::new("transaction", self.id.as_slice()));
    MessageBuilder {
     session: self.session,
     frame: send_frame
    }
  }

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

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

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