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

#![crate_name = "stomp"]
#![crate_type = "lib"]

#![feature(collections)]
#![feature(core)]
#![feature(std_misc)]
#![feature(io)]

#[macro_use]
extern crate log;
extern crate collections;

use std::old_io::IoResult;
use session::Session;
use connection::Connection;

pub fn connect<'a>(ip_address: &str, port: u16) -> IoResult<Session<'a>> {
  connect_with_heartbeat(ip_address, port, 0, 0)
}

pub fn connect_with_heartbeat<'a>(ip_address: &str, port: u16, tx_heartbeat_ms: u32, rx_heartbeat_ms: u32) -> IoResult<Session<'a>> {
  let connection = try!(Connection::new(ip_address, port));
  connection.start_session(tx_heartbeat_ms, rx_heartbeat_ms)
}

pub fn connect_with_credentials<'a>(ip_address: &str, port: u16, login: &str, passcode: &str) -> IoResult<Session<'a>> {
  connect_with_credentials_and_heartbeat(ip_address, port, login, passcode, 0, 0)
}

pub fn connect_with_credentials_and_heartbeat<'a>(ip_address: &str, port: u16, login: &str, passcode: &str, tx_heartbeat_ms: u32, rx_heartbeat_ms: u32) -> IoResult<Session<'a>> {
  let connection = try!(Connection::new(ip_address, port));
  connection.start_session_with_credentials(login, passcode, tx_heartbeat_ms, rx_heartbeat_ms)
}

pub mod connection;
pub mod header;
pub mod frame;
pub mod session;
pub mod subscription;
pub mod transaction;