Struct bb8_lapin::LapinConnectionManager

pub struct LapinConnectionManager { /* fields omitted */ }

A bb8::ManageConnection implementation for lapin::Connections.

Example

use bb8_lapin::prelude::*;

async fn example() {
    let manager = LapinConnectionManager::new("amqp://guest:guest@127.0.0.1:5672//", ConnectionProperties::default());
    let pool = bb8::Pool::builder()
        .max_size(15)
        .build(manager)
        .await
        .unwrap();

    for _ in 0..20 {
        let pool = pool.clone();
        tokio::spawn(async move {
            let conn = pool.get().await.unwrap();
            // use the connection
            // it will be returned to the pool when it falls out of scope.
        });
    }
}

Implementations

impl LapinConnectionManager

pub fn new(amqp_address: &str, conn_properties: ConnectionProperties) -> Self

Initialize the connection manager with the data needed to create new connections. Refer to the documentation of lapin::ConnectionProperties for further details on the available connection parameters.

Example

let manager = bb8_lapin::LapinConnectionManager::new("amqp://guest:guest@127.0.0.1:5672//", lapin::ConnectionProperties::default());

Trait Implementations

impl Debug for LapinConnectionManager

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

Formats the value using the given formatter.

impl ManageConnection for LapinConnectionManager

type Connection = Connection

The connection type this manager deals with.

type Error = Error

The error type returned by Connections.

fn connect<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<Self::Connection, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Attempts to create a new connection.

fn is_valid<'life0, 'async_trait>(
    &'life0 self,
    conn: Self::Connection
) -> Pin<Box<dyn Future<Output = Result<Self::Connection, Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Determines if the connection is still connected to the database.

fn has_broken(&self, conn: &mut Self::Connection) -> bool

Synchronously determine if the connection is no longer usable, if possible.