Struct Connection

pub struct Connection { /* private fields */ }

👎Deprecated: use lapin instead

Implementations

impl Connection

pub fn connect( uri: &str, options: ConnectionProperties, ) -> Confirmation<Connection>

👎Deprecated: use lapin instead

Connect to an AMQP Server

pub fn connect_uri( uri: AMQPUri, options: ConnectionProperties, ) -> Confirmation<Connection>

👎Deprecated: use lapin instead

Connect to an AMQP Server

pub fn create_channel(&self) -> Confirmation<Channel>

👎Deprecated: use lapin instead

pub fn run(&self) -> Result<(), Error>

👎Deprecated: use lapin instead

Block current thread while the connection is still active. This is useful when you only have a consumer and nothing else keeping your application “alive”.

pub fn on_error<E: Fn() + Send + 'static>(&self, handler: Box<E>)

👎Deprecated: use lapin instead

pub fn configuration(&self) -> &Configuration

👎Deprecated: use lapin instead

pub fn status(&self) -> &ConnectionStatus

👎Deprecated: use lapin instead

pub fn close(&self, reply_code: ShortUInt, reply_text: &str) -> Confirmation<()>

👎Deprecated: use lapin instead

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Connection

fn default() -> Self

Returns the “default value” for a type.

impl Evented for Connection

fn register( &self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt, ) -> Result<()>

Register self with the given Poll instance.

fn reregister( &self, poll: &Poll, token: Token, interest: Ready, opts: PollOpt, ) -> Result<()>

Re-register self with the given Poll instance.

fn deregister(&self, poll: &Poll) -> Result<()>

Deregister self from the given Poll instance