stomp 0.6.0

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

use session::Session;
use frame::Frame;
use option_setter::OptionSetter;
use std::old_io::IoResult;

pub struct MessageBuilder <'a> {
  pub session: &'a Session<'a>,
  pub frame: Frame
}

impl <'a> MessageBuilder <'a> {
  #[allow(dead_code)] 
  pub fn send(self) -> IoResult<()> {
    self.session.send(self.frame)
  }

  #[allow(dead_code)] 
  pub fn with<T>(self, option_setter: T) -> MessageBuilder<'a> where T: OptionSetter<MessageBuilder<'a>> {
    option_setter.set_option(self) 
  } 
}