stomp 0.7.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, 'session: 'a> {
  pub session: &'a mut Session<'session>,
  pub frame: Frame
}

impl <'a, 'session> MessageBuilder <'a, 'session> {
  #[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, 'session> where T: OptionSetter<MessageBuilder<'a, 'session>> {
    option_setter.set_option(self) 
  } 
}