[−][src]Struct waxosuit_guest::msg::MessageBroker
Exposes message broker functionality to guest modules
Methods
impl MessageBroker
[src]
pub fn publish(
&self,
subject: &str,
reply_to: Option<&str>,
payload: &[u8]
) -> Result<()>
[src]
&self,
subject: &str,
reply_to: Option<&str>,
payload: &[u8]
) -> Result<()>
Publishes a new message on the given subject with an optional reply-to
pub fn request(
&self,
subject: &str,
payload: &[u8],
timeout_ms: u64
) -> Result<Vec<u8>>
[src]
&self,
subject: &str,
payload: &[u8],
timeout_ms: u64
) -> Result<Vec<u8>>
Publishes a message on the given subject and awaits a reply on an inbox subject
Auto Trait Implementations
impl Send for MessageBroker
impl Sync for MessageBroker
impl Unpin for MessageBroker
impl UnwindSafe for MessageBroker
impl RefUnwindSafe for MessageBroker
Blanket Implementations
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = !
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,