Struct apalis_sql::postgres::PgListen

pub struct PgListen { /* private fields */ }

Available on crate feature postgres only.

A listener that listens to Postgres notifications

Implementations

impl PgListen

pub async fn new(pool: PgPool) -> Result<Self, Error>

Build a new listener.

Maintaining a connection can be expensive, its encouraged you only create one PgListen and share it with multiple PostgresStorage

pub fn subscribe<T: Job>(&mut self) -> PgSubscription

Add a new subscription

pub async fn listen(self) -> Result<(), Error>

Start listening to jobs

Trait Implementations

impl Debug for PgListen

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

Formats the value using the given formatter.