Struct Eventbus

pub struct Eventbus { /* private fields */ }

The core struct to communicate with vert.x eventbus. Can be created by calling Eventbus::connect.

Implementations

impl Eventbus

pub fn connect( address: IpAddr, port: u16, ) -> impl Future<Item = (Eventbus, EventbusReadStream, EventbusWriteFuture), Error = IoError>

pub fn register( &self, address: String, headers: Option<Value>, ) -> Result<ResponseStream, SendError<Request>>

pub fn unregister(&self, address: String)

pub fn ping(&mut self) -> Result<(), SendError<Request>>

pub fn send( &self, address: String, message: Value, ) -> Result<(), SendError<Request>>

send with no reply

pub fn send_reply( &self, address: String, message: Value, ) -> Result<ResponseFut, SendError<Request>>

send with reply

pub fn publish( &mut self, address: String, message: Value, ) -> Result<(), SendError<Request>>