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
30
31
32
33
34

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

diesel_functions!(
    diesel_async::AsyncConnection<Backend = diesel::pg::Pg>,
    diesel_async::RunQueryDsl,
    transform_result_async
);

impl_queue!(&mut diesel_async::AsyncPgConnection, identity_macro);

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

#[cfg(feature = "diesel-async-pool")]
impl_queue!(
    &mut bb8::PooledConnection<
        '_,
        diesel_async::pooled_connection::AsyncDieselConnectionManager<
            diesel_async::AsyncPgConnection,
        >,
    >,
    identity_macro
);

#[cfg(feature = "diesel-async-pool")]
impl_queue!(
    &diesel_async::pooled_connection::bb8::Pool<diesel_async::AsyncPgConnection>,
    transform_self_acquire_connection_async
);