Struct vertx_rust::vertx::EventBus

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

Implementations

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

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

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

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

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(Arc<Message>, Arc<EventBus<CM>>) -> BoxFuture<()> + Send + 'static + Sync + RefUnwindSafe,

Trait Implementations

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