pgmq 0.34.0-alpha.5

A distributed message queue for Rust applications, on Postgres.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use crate::queue::diesel::diesel_functions;
use crate::queue::macros::{identity_macro, impl_queue};

diesel_functions!(
    diesel::connection::LoadConnection<Backend = diesel::pg::Pg>,
    diesel::RunQueryDsl,
    identity_macro
);

impl_queue!(&mut diesel::PgConnection, identity_macro);

#[cfg(feature = "diesel-sync-pool")]
macro_rules! transform_self_acquire_connection {
    ($self:ident) => {
        &mut ($self.get()?)
    };
}

#[cfg(feature = "diesel-sync-pool")]
impl_queue!(
    &mut r2d2::PooledConnection<diesel::r2d2::ConnectionManager<diesel::PgConnection>>,
    identity_macro
);

#[cfg(feature = "diesel-sync-pool")]
impl_queue!(
    &r2d2::Pool<diesel::r2d2::ConnectionManager<diesel::PgConnection>>,
    transform_self_acquire_connection
);