Struct Connection 

pub struct Connection { /* private fields */ }

Simple RabbitMQ connection wrapper

Implementations

impl Connection

pub async fn new(url: &str) -> Result<Arc<Self>, RustRabbitError>

Create a new connection

Arguments

• url - RabbitMQ connection URL (e.g., “amqp://localhost:5672”)

Example

use rust_rabbit::Connection;

let connection = Connection::new("amqp://guest:guest@localhost:5672").await?;

pub async fn with_config( config: ConnectionConfig, ) -> Result<Arc<Self>, RustRabbitError>

Create a new connection with custom configuration

pub fn url(&self) -> &str

Get connection URL for debugging

pub async fn is_connected(&self) -> bool

Check if connection is active

pub async fn create_channel(&self) -> Result<Channel, RustRabbitError>

Create a new channel

Automatically reconnects if the connection is lost.

pub async fn reconnect(&self) -> Result<(), RustRabbitError>

Manually reconnect

pub async fn close(&self) -> Result<(), RustRabbitError>

Close the connection

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.