Struct amqp::Session
[−]
[src]
pub struct Session { /* fields omitted */ }
Methods
impl Session
[src]
fn open_url(url_string: &str) -> Result<Session, AMQPError>
Use open_url
to create new amqp session from a "amqp url"
Arguments
url_string
: The format is:amqp://username:password@host:port/virtual_host
Most of the params have their default, so you can just pass this:
"amqp://localhost//"
and it will connect to rabbitmq server,
running on localhost
on port 5672
,
with login "guest"
, password: "guest"
to vhost "/"
fn new(options: Options) -> Result<Session, AMQPError>
Initialize new rabbitmq session. You can use default options:
Example
use std::default::Default; use amqp::{Options, Session}; let session = match Session::new(Options { .. Default::default() }){ Ok(session) => session, Err(error) => panic!("Failed openning an amqp session: {:?}", error) };
fn open_channel(&mut self, channel_id: u16) -> Result<Channel, AMQPError>
open_channel
will open a new amqp channel:
Arguments
channel_id
- channel number
Exmaple
use std::default::Default; use amqp::{Options, Session}; let mut session = Session::new(Options { .. Default::default() }).ok().unwrap(); let channel = match session.open_channel(1){ Ok(channel) => channel, Err(error) => panic!("Failed openning channel: {:?}", error) };