Struct eventific_rabbitmq::RabbitMqListener

pub struct RabbitMqListener { /* fields omitted */ }

Methods

impl RabbitMqListener

pub fn new(amqp_address: &str, queue_postfix: &str) -> Self

Trait Implementations

impl Listener for RabbitMqListener

fn init(
    &mut self,
    logger: &Logger,
    service_name: &str
) -> Box<dyn Future<Item = (), Error = NotificationError> + Send>

fn listen(
    &self
) -> Box<dyn Stream<Item = Uuid, Error = NotificationError> + Send>