Struct vertx_rust::vertx::EventBus

pub struct EventBus<CM: 'static + ClusterManager + Send + Sync> { /* fields omitted */ }

Implementations

impl<CM: 'static + ClusterManager + Send + Sync> EventBus<CM>

pub fn new(options: EventBusOptions) -> EventBus<CM>

pub fn consumer<OP>(&self, address: &str, op: OP) where
    OP: Fn(&mut Message, Arc<EventBus<CM>>) + Send + 'static + Sync, 

pub fn local_consumer<OP>(&self, address: &str, op: OP) where
    OP: Fn(&mut Message, Arc<EventBus<CM>>) + Send + 'static + Sync, 

pub fn send(&self, address: &str, request: Body)

pub fn publish(&self, address: &str, request: Body)

pub fn request<OP>(&self, address: &str, request: Body, op: OP) where
    OP: Fn(&Message, Arc<EventBus<CM>>) + Send + 'static + Sync,