Struct wascc_actor::messaging::MessageBrokerHostBinding

pub struct MessageBrokerHostBinding { /* fields omitted */ }

Exposes message broker functionality to actor modules

Implementations

impl MessageBrokerHostBinding

pub fn publish(
    &self,
    subject: &str,
    reply_to: Option<&str>,
    payload: &[u8]
) -> HandlerResult<()>

Publishes a message on a given subject with an optional reply subject

pub fn request(
    &self,
    subject: &str,
    payload: &[u8],
    timeout_ms: u64
) -> HandlerResult<Vec<u8>>

Publishes a message and expects a reply to come back within a given timeout (in milliseconds)