Struct BaseListener

pub struct BaseListener {
    pub stan: Client,
    pub stream_name: String,
    pub subject: String,
    pub queue_group_name: String,
    pub ack_wait: Duration,
}

Fields

stan: Client

stream_name: String

subject: String

queue_group_name: String

ack_wait: Duration

Implementations

impl BaseListener

pub fn new( stan: Client, stream_name: String, subject: String, queue_group_name: String, ) -> Self

pub fn consumer_config(&self) -> Config

Trait Implementations

impl Listener for BaseListener

fn listen<'life0, 'life1, 'async_trait, T, U>( &'life0 self, on_event_message: &'life1 T, app_data: Option<Arc<U>>, ) -> Pin<Box<dyn Future<Output = Result<(), ListenerError>> + Send + 'async_trait>>

where T: 'async_trait + OnEventMessage + Send + Sync, U: 'async_trait + Any + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,