Struct LapinConnectionManager 

pub struct LapinConnectionManager { /* private fields */ }

An r2d2::ManageConnection for lapin::Connections.

Example

use lapin::ConnectionProperties;
use r2d2_lapin::prelude::*;
use std::thread;

let manager = LapinConnectionManager::new("amqp://guest:guest@127.0.0.1:5672//", &ConnectionProperties::default());
let pool = r2d2::Pool::builder()
    .max_size(15)
    .build(manager)
    .unwrap();

for _ in 0..20 {
    let pool = pool.clone();
    thread::spawn(move || {
        let conn = pool.get().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

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

Example

let manager = r2d2_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(&self) -> Result<Self::Connection, Self::Error>

Attempts to create a new connection.

fn is_valid(&self, conn: &mut Self::Connection) -> Result<(), Self::Error>

Determines if the connection is still connected to the database.

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

Quickly determines if the connection is no longer usable.